Skip to content
Snippets Groups Projects

ensure we don't send repeat messages to external systems on workflow recovery

Merged Charlotte Hausman requested to merge fix_external_messaging into main
3 files
+ 29
6
Compare changes
  • Side-by-side
  • Inline
Files
3
@@ -25,6 +25,7 @@ from workspaces.workflow.schema import (
WorkflowTemplate,
ProcessingSite,
Controller,
WorkflowProgress,
)
from workspaces.workflow.services.interfaces import WorkflowInfoIF
@@ -57,6 +58,9 @@ class FakeWorkflowInfo(WorkflowInfoIF):
else:
return NotImplementedError
def lookup_workflow_stage(self, request_id: int, stage: str) -> Union[WorkflowProgress, None]:
return NotImplementedError
def all_processing_sites(self) -> List[ProcessingSite]:
return [self.lookup_processing_site("NAASC")]
Loading