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

SIENTIAPDE-1712

Browse Source
This commit is contained in:
vitor-aignosi
2026-03-23 12:06:50 -03:00
parent 69cbd08913
commit 50a7a73a8d
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
laborious/activities/gates.py
View File

@@ -233,10 +233,13 @@ class Gates(MinioManager):
""" """
metadata = input_data['metadata'] metadata = input_data['metadata']
self.info('Performing mlflow response gate...', metadata) self.info('Performing mlflow response gate...', metadata)
raw_data = input_data['data']
filters = input_data['filters'] filters = input_data['filters']
self.debug(f'Input data: \n {create_sample_dict(raw_data, max_items=5, max_depth=5)}', metadata)
self.debug(f'Filters: {filters}', metadata)
payload = MinioDataFramePayload.from_dict(input_data['data']) payload = MinioDataFramePayload.from_dict(raw_data)
data = await payload.retrieve(self.minio_repository, metadata) data = await payload.retrieve(self.minio_repository, metadata)
gate_type = input_data['type'] gate_type = input_data['type']
@@ -244,9 +247,6 @@ class Gates(MinioManager):
filter_output = [] filter_output = []
self.debug(f'Input data: \n {create_sample_dict(data, max_items=5, max_depth=5)}', metadata)
self.debug(f'Filters: {filters}', metadata)
comments = [] comments = []
status = payload.status or {} status = payload.status or {}