diff --git a/scouter/workflow/scouter.py b/scouter/workflow/scouter.py index 292834b..ecf0716 100644 --- a/scouter/workflow/scouter.py +++ b/scouter/workflow/scouter.py @@ -55,6 +55,7 @@ class Scouter: return input_data['data'] = data + input_data['metadata'] = metadata await workflow.execute_child_workflow( 'core_scouter', diff --git a/scouter/workflow/sub_workflows/core_scouter.py b/scouter/workflow/sub_workflows/core_scouter.py index 9628aea..de0e79a 100644 --- a/scouter/workflow/sub_workflows/core_scouter.py +++ b/scouter/workflow/sub_workflows/core_scouter.py @@ -32,14 +32,7 @@ class CoreScouter: retention_time (int): The retention time for data in redis in seconds. """ - metadata = { - 'metadata': { - 'model_id': input_data['model_id'], - 'model_name': input_data['model_name'], - 'schedule_name': input_data['schedule_name'], - 'workflow_name': input_data['workflow_name'] - } - } + metadata = input_data['metadata'] filtered_data = await workflow.execute_local_activity_method( Activities.data_quality_gate,