feat(engine): Add logging when run status changes

tracecat/runner/actions.py

@@ -881,6 +881,7 @@ async def run_action(
 # TODO: Move these calls into a logger
 async def log_create_action_run(action_run: ActionRun) -> ActionRunResponse:
     """Create a workflow run."""
+    logger.info(f"Log create action run {action_run.id}")
     action_id = action_key_to_id(action_run.action_key)
     params = CreateActionRunParams(
         action_run_id=action_run.id,
@@ -896,6 +897,7 @@ async def log_create_action_run(action_run: ActionRun) -> ActionRunResponse:
 
 async def log_update_action_run(action_run: ActionRun, *, status: RunStatus) -> None:
     """Update a workflow run."""
+    logger.info(f"Log update action run {action_run.id} with status {status}.")
     action_id = action_key_to_id(action_run.action_key)
     params = UpdateActionRunParams(status=status)
     async with AuthenticatedAPIClient(http2=True) as client:

tracecat/runner/app.py

@@ -402,6 +402,7 @@ async def run_workflow(
         for running_task in running_jobs_store.values():
             running_task.cancel()
 
+    # TODO: Update this to update with status 'failure' if any action fails
     await update_workflow_run(
         workflow_id=workflow_id, workflow_run_id=workflow_run_id, status=run_status
     )

tracecat/runner/workflows.py

@@ -149,6 +149,7 @@ async def update_workflow_run(
     status: RunStatus,
 ) -> None:
     """Update a workflow run."""
+    logger.info(f"Log update workflow run {workflow_run_id} with status {status}")
     params = UpdateWorkflowRunParams(status=status)
     async with AuthenticatedAPIClient(http2=True) as client:
         response = await client.post(