diff --git a/orchestrator/workflows/subworkflows/process_notifications.py b/orchestrator/workflows/subworkflows/process_notifications.py index f868515..7809ac1 100644 --- a/orchestrator/workflows/subworkflows/process_notifications.py +++ b/orchestrator/workflows/subworkflows/process_notifications.py @@ -70,7 +70,7 @@ class ProcessNotifications: ) if not log_report: - return + return {} # Format the log report to a dataframe to be stored in the database log_report = await workflow.execute_local_activity_method( diff --git a/run_local.sh b/run_local.sh index 4ff3c78..af97775 100755 --- a/run_local.sh +++ b/run_local.sh @@ -15,4 +15,4 @@ else fi echo "Starting orchestrator application..." -python -m orchestrator.worker.worker +exec python -m orchestrator.worker.worker