diff --git a/orchestrator/workflows/orchestrator.py b/orchestrator/workflows/orchestrator.py index cd0381f..816919b 100644 --- a/orchestrator/workflows/orchestrator.py +++ b/orchestrator/workflows/orchestrator.py @@ -137,7 +137,7 @@ class Orchestrator: start_to_close_timeout=timedelta(seconds=60) ) - normalize_schedules_handler = workflow.start_local_activity_method( + normalize_schedules_handler = workflow.start_activity_method( Activities.normalize_schedules, { **metadata, diff --git a/requirements.txt b/requirements.txt index 214530b..768af58 100644 --- a/requirements.txt +++ b/requirements.txt @@ -4,4 +4,4 @@ sqlalchemy redis couchbase pymongo -git+ssh://git@github.com/Aignosi/sientia-dataops-library.git@1.3.0 +/home/grezewave/Documents/projects/sientia/sientia-dataops-library diff --git a/tests/orchestrator/workflows/test_orchestrator.py b/tests/orchestrator/workflows/test_orchestrator.py index 86d45ee..a55362e 100644 --- a/tests/orchestrator/workflows/test_orchestrator.py +++ b/tests/orchestrator/workflows/test_orchestrator.py @@ -154,7 +154,7 @@ async def test_run(workflow_mock, orchestrator): ) ]) - workflow_mock.start_local_activity_method.assert_has_calls([ + workflow_mock.start_activity_method.assert_has_calls([ call( Activities.normalize_schedules, {