diff --git a/laborious/activities/gates.py b/laborious/activities/gates.py index 1bf37f2..cac6c38 100644 --- a/laborious/activities/gates.py +++ b/laborious/activities/gates.py @@ -233,10 +233,13 @@ class Gates(MinioManager): """ metadata = input_data['metadata'] self.info('Performing mlflow response gate...', metadata) - + raw_data = input_data['data'] 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) gate_type = input_data['type'] @@ -244,9 +247,6 @@ class Gates(MinioManager): 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 = [] status = payload.status or {}