From 5dc2971d8c33b946813676c9e725de5ca8e76e3c Mon Sep 17 00:00:00 2001 From: vitor-aignosi Date: Mon, 27 Oct 2025 10:16:57 -0300 Subject: [PATCH] SIENTIAPDE-1314 SIENTIAPDE-1314: Update workflow name from 'sub_core_scouter' to 'subworkflow.core_scouter' in scouter.py and core_scouter.py, and adjust test references accordingly in 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 2da1c4c..5888627 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('sub_core_scouter', input_data) + await workflow.execute_child_workflow('subworkflow.core_scouter', input_data) diff --git a/scouter/workflow/sub_workflows/core_scouter.py b/scouter/workflow/sub_workflows/core_scouter.py index 575d4f5..1bbc4cb 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='sub_core_scouter') +@workflow.defn(name='subworkflow.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 28e8078..ba47683 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( - 'sub_core_scouter', + 'subworkflow.core_scouter', { 'metadata': expected_metadata, 'topic': 'test_topic',