made everything complete not compelted

This commit is contained in:
Jun-te Kim 2026-04-21 20:37:34 +00:00
parent b0a4a98063
commit d7b8ca34bf
3 changed files with 6 additions and 6 deletions

View file

@ -563,14 +563,14 @@ def handler(event, context, local=False):
except Exception as s3_error:
logger.error(f"Failed to save results to S3: {s3_error}")
# Mark subtask as completed
# Mark subtask as complete
try:
subtask_interface.update_subtask_status(
subtask_id,
"completed",
"complete",
outputs={"rows_processed": "todo -> show sensible output"},
)
logger.info(f"Marked subtask {subtask_id} as completed")
logger.info(f"Marked subtask {subtask_id} as complete")
except Exception as db_error:
logger.error(f"Failed to mark subtask as completed: {db_error}")

View file

@ -195,7 +195,7 @@ class SubTaskInterface:
task.status = "failed"
task.job_completed = now
elif all(s in ("complete", "completed") for s in statuses):
elif all(s == "complete" for s in statuses):
task.status = "complete"
task.job_completed = now

View file

@ -263,10 +263,10 @@ def handler(event, context, local=False):
bucket_name=bucket_name,
)
# Mark subtask as completed
# Mark subtask as complete
subtask_interface.update_subtask_status(
subtask_id,
"completed",
"complete",
outputs={"rows_processed": "completed"},
)