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

SIENTIAPDE-1110

Browse Source 
Add metadata to input_data in Scouter and update CoreScouter to use it
This commit is contained in:
vitor-aignosi
2025-06-27 10:07:43 -03:00
parent 74a2d9aa3e
commit 9afb74be21
2 changed files with 2 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
scouter/workflow/scouter.py
View File

@@ -55,6 +55,7 @@ class Scouter:
return return
input_data['data'] = data input_data['data'] = data
input_data['metadata'] = metadata
await workflow.execute_child_workflow( await workflow.execute_child_workflow(
'core_scouter', 'core_scouter',

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

@@ -32,14 +32,7 @@ class CoreScouter:
retention_time (int): The retention time for data in redis in seconds. retention_time (int): The retention time for data in redis in seconds.
""" """
metadata = { metadata = input_data['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']
}
}
filtered_data = await workflow.execute_local_activity_method( filtered_data = await workflow.execute_local_activity_method(
Activities.data_quality_gate, Activities.data_quality_gate,