gitea_admin/sientia-dataops-orchestrator_temporal
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SIENTIAPDE-1314

Browse Source 
Refactor workflow calls to use subworkflow naming convention for load_notification_package and process_notifications in alerts and reports modules. Update corresponding tests to reflect these changes.
This commit is contained in:
vitor-aignosi
2025-10-27 10:24:16 -03:00
parent de08468dbe
commit 1e6616cfc2
6 changed files with 16 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
tests/orchestrator/workflows/test_alerts.py
View File

@@ -31,7 +31,7 @@ async def test_run_full_flow(workflow_mock, alerts):
workflow_mock.execute_child_workflow.assert_has_calls(
[
call(
'load_notification_package',
'subworkflow.load_notification_package',
{**input_data, 'metadata': metadata, 'base_data_filter': {'level': 'ERROR'}},
)
]
@@ -40,7 +40,7 @@ async def test_run_full_flow(workflow_mock, alerts):
workflow_mock.execute_child_workflow.assert_has_calls(
[
call(
'process_notifications',
'subworkflow.process_notifications',
{
'metadata': metadata,
'mail_type': 'Alerts',
@@ -104,7 +104,7 @@ async def test_run_no_data(workflow_mock, alerts):
workflow_mock.execute_child_workflow.assert_has_calls(
[
call(
'load_notification_package',
'subworkflow.load_notification_package',
{**input_data, 'metadata': metadata, 'base_data_filter': {'level': 'ERROR'}},
)
]

6
tests/orchestrator/workflows/test_reports.py
View File

@@ -31,7 +31,7 @@ async def test_run_full_flow(workflow_mock, reports):
workflow_mock.execute_child_workflow.assert_has_calls(
[
call(
'load_notification_package',
'subworkflow.load_notification_package',
{**input_data, 'metadata': metadata, 'base_data_filter': {}},
)
]
@@ -40,7 +40,7 @@ async def test_run_full_flow(workflow_mock, reports):
workflow_mock.execute_child_workflow.assert_has_calls(
[
call(
'process_notifications',
'subworkflow.process_notifications',
{
'metadata': metadata,
'mail_type': 'Reports',
@@ -88,7 +88,7 @@ async def test_run_no_data(workflow_mock, reports):
workflow_mock.execute_child_workflow.assert_has_calls(
[
call(
'load_notification_package',
'subworkflow.load_notification_package',
{**input_data, 'metadata': metadata, 'base_data_filter': {}},
)
]