Skip to content

Commit

Permalink
fix: improve parsing bytewax job status
Browse files Browse the repository at this point in the history
Signed-off-by: Hai Nguyen <quanghai.ng1512@gmail.com>
  • Loading branch information
sudohainguyen authored and achals committed Nov 14, 2023
1 parent 9cf9d96 commit 5983f40
Showing 1 changed file with 16 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -35,13 +35,22 @@ def status(self):
if job_status.active is not None:
if job_status.completion_time is None:
return MaterializationJobStatus.RUNNING
elif job_status.failed is not None:
self._error = Exception(f"Job {self.job_id()} failed")
return MaterializationJobStatus.ERROR
elif job_status.active is None:
if job_status.completion_time is not None:
if job_status.conditions[0].type == "Complete":
return MaterializationJobStatus.SUCCEEDED
else:
if (
job_status.completion_time is not None
and job_status.conditions[0].type == "Complete"
):
return MaterializationJobStatus.SUCCEEDED

if (
job_status.conditions is not None
and job_status.conditions[0].type == "Failed"
):
self._error = Exception(
f"Job {self.job_id()} failed with reason: "
f"{job_status.conditions[0].message}"
)
return MaterializationJobStatus.ERROR
return MaterializationJobStatus.WAITING

def should_be_retried(self):
Expand Down

0 comments on commit 5983f40

Please sign in to comment.