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

SIENTIAPDE-1314

Browse Source 
SIENTIAPDE-1314: Rename core_scouter workflow to sub_core_scouter and update references in scouter.py and test_scouter.py for consistency.
This commit is contained in:
vitor-aignosi
2025-10-27 10:11:07 -03:00
parent 25838c26a6
commit 6af45c7476
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
scouter/workflow/scouter.py
View File

@@ -113,4 +113,4 @@ class Scouter:
input_data['data'] = data input_data['data'] = data
input_data['metadata'] = metadata input_data['metadata'] = metadata
await workflow.execute_child_workflow('core_scouter', input_data) await workflow.execute_child_workflow('sub_core_scouter', input_data)

2
scouter/workflow/sub_workflows/core_scouter.py
View File

@@ -10,7 +10,7 @@ with workflow.unsafe.imports_passed_through():
from scouter.activities.activities import Activities from scouter.activities.activities import Activities
@workflow.defn(name='core_scouter') @workflow.defn(name='sub_core_scouter')
class CoreScouter: class CoreScouter:
""" """
Core data processing workflow that handles data quality, aggregation, and export. Core data processing workflow that handles data quality, aggregation, and export.

2
tests/workflow/test_scouter.py
View File

@@ -75,7 +75,7 @@ async def test_scouter_workflow(mock_workflow, scouter):
) )
mock_workflow.execute_child_workflow.assert_called_once_with( mock_workflow.execute_child_workflow.assert_called_once_with(
'core_scouter', 'sub_core_scouter',
{ {
'metadata': expected_metadata, 'metadata': expected_metadata,
'topic': 'test_topic', 'topic': 'test_topic',