SIENTIAPDE-1163
refactor: update requirements to point to local sientia-dataops-library path; modify orchestration and test files to use start_activity_method for consistency
This commit is contained in:
@@ -137,7 +137,7 @@ class Orchestrator:
|
|||||||
start_to_close_timeout=timedelta(seconds=60)
|
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,
|
Activities.normalize_schedules,
|
||||||
{
|
{
|
||||||
**metadata,
|
**metadata,
|
||||||
|
|||||||
@@ -4,4 +4,4 @@ sqlalchemy
|
|||||||
redis
|
redis
|
||||||
couchbase
|
couchbase
|
||||||
pymongo
|
pymongo
|
||||||
git+ssh://git@github.com/Aignosi/sientia-dataops-library.git@1.3.0
|
/home/grezewave/Documents/projects/sientia/sientia-dataops-library
|
||||||
|
|||||||
@@ -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(
|
call(
|
||||||
Activities.normalize_schedules,
|
Activities.normalize_schedules,
|
||||||
{
|
{
|
||||||
|
|||||||
Reference in New Issue
Block a user