From 6af45c7476b11ec50af9adf5482444df38fccdaa Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Mon, 27 Oct 2025 10:11:07 -0300 Subject: [PATCH] SIENTIAPDE-1314 SIENTIAPDE-1314: Rename core_scouter workflow to sub_core_scouter and update references in scouter.py and test_scouter.py for consistency. --- scouter/workflow/scouter.py | 2 +- scouter/workflow/sub_workflows/core_scouter.py | 2 +- tests/workflow/test_scouter.py | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/scouter/workflow/scouter.py b/scouter/workflow/scouter.py index e028bc6..2da1c4c 100644 --- a/scouter/workflow/scouter.py +++ b/scouter/workflow/scouter.py @@ -113,4 +113,4 @@ class Scouter: input_data['data'] = data input_data['metadata'] = metadata - await workflow.execute_child_workflow('core_scouter', input_data) + await workflow.execute_child_workflow('sub_core_scouter', input_data) diff --git a/scouter/workflow/sub_workflows/core_scouter.py b/scouter/workflow/sub_workflows/core_scouter.py index 04d0984..575d4f5 100644 --- a/scouter/workflow/sub_workflows/core_scouter.py +++ b/scouter/workflow/sub_workflows/core_scouter.py @@ -10,7 +10,7 @@ with workflow.unsafe.imports_passed_through(): from scouter.activities.activities import Activities -@workflow.defn(name='core_scouter') +@workflow.defn(name='sub_core_scouter') class CoreScouter: """ Core data processing workflow that handles data quality, aggregation, and export. diff --git a/tests/workflow/test_scouter.py b/tests/workflow/test_scouter.py index 3e16666..28e8078 100644 --- a/tests/workflow/test_scouter.py +++ b/tests/workflow/test_scouter.py @@ -75,7 +75,7 @@ async def test_scouter_workflow(mock_workflow, scouter): ) mock_workflow.execute_child_workflow.assert_called_once_with( - 'core_scouter', + 'sub_core_scouter', { 'metadata': expected_metadata, 'topic': 'test_topic',