SIENTIAPDE-1712
Add status parameter to MinioDataFramePayload for improved data tracking
This commit is contained in:
@@ -205,7 +205,7 @@ class MinioDataFramePayload:
|
|||||||
last_timestamp = max(dataframe['timestamp'].values.tolist())
|
last_timestamp = max(dataframe['timestamp'].values.tolist())
|
||||||
|
|
||||||
if cls.estimate_size_bytes(dataframe) <= OFFLOAD_THRESHOLD_BYTES:
|
if cls.estimate_size_bytes(dataframe) <= OFFLOAD_THRESHOLD_BYTES:
|
||||||
return cls(data=dataframe.to_dict(), last_timestamp=last_timestamp)
|
return cls(data=dataframe.to_dict(), last_timestamp=last_timestamp, status=status)
|
||||||
|
|
||||||
timestamp = now().strftime(DATETIME_FORMAT_FILENAME)
|
timestamp = now().strftime(DATETIME_FORMAT_FILENAME)
|
||||||
object_key, object_prefix = _build_object_key(model_name, operation, timestamp)
|
object_key, object_prefix = _build_object_key(model_name, operation, timestamp)
|
||||||
|
|||||||
Reference in New Issue
Block a user