1b20c943554d3c2d35ddba09afe4cd1c6edb2ed7,perfkitbenchmarker/providers/gcp/gcp_dpb_dataproc.py,GcpDpbDataproc,SubmitJob,#GcpDpbDataproc#Any#Any#Any#Any#Any#Any#Any#Any#Any#Any#Any#,187

Before Change

      return {dpb_service.SUCCESS: False}

    stats = self._GetStats(stdout)
    stats[dpb_service.SUCCESS] = True
    return stats

  def SetClusterProperty(self):

After Change

      if state["state"] == "PENDING":
        pending_time = GcpDpbDataproc._ParseTime(state["stateStartTime"])
      elif state["state"] == "RUNNING":
        start_time = GcpDpbDataproc._ParseTime(state["stateStartTime"])

    assert pending_time and start_time and done_time

    return dpb_service.JobResult(
        run_time=(done_time - start_time).total_seconds(),
        pending_time=(start_time - pending_time).total_seconds())

  def SetClusterProperty(self):
    pass

Instances