diff --git a/src/utils/job/jobs.py b/src/utils/job/jobs.py index 3f85d45e4..adad6ffd3 100644 --- a/src/utils/job/jobs.py +++ b/src/utils/job/jobs.py @@ -380,8 +380,8 @@ def execute(self, context: JobExecutionContext, if workflow_config.workflow_log.credential is None: return JobResult( - success=False, - error='Workflow log credential is not set', + status=JobStatus.FAILED_NO_RETRY, + message='Workflow log credential is not set', ) storage_client = storage.Client.create( @@ -1388,8 +1388,8 @@ def execute(self, context: JobExecutionContext, workflow_config = context.postgres.get_workflow_configs() if workflow_config.workflow_log.credential is None: return JobResult( - success=False, - error='Workflow log credential is not set', + status=JobStatus.FAILED_NO_RETRY, + message='Workflow log credential is not set', ) storage_client = storage.Client.create( data_credential=workflow_config.workflow_log.credential, @@ -1728,8 +1728,8 @@ def execute(self, context: JobExecutionContext, if workflow_config.workflow_app.credential is None: return JobResult( - success=False, - error='Workflow app credential is not set', + status=JobStatus.FAILED_NO_RETRY, + message='Workflow app credential is not set', ) storage_client = storage.Client.create( @@ -1789,8 +1789,8 @@ def execute(self, context: JobExecutionContext, if workflow_config.workflow_app.credential is None: return JobResult( - success=False, - error='Workflow app credential is not set', + status=JobStatus.FAILED_NO_RETRY, + message='Workflow app credential is not set', ) storage_client = storage.Client.create(