Testing out persisting output to minio

fairtracks · Sep 24, 2024 · 540b7c3 · 540b7c3
1 parent 6387539
commit 540b7c3
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/omnipy/modules/prefect/engine/prefect.py b/src/omnipy/modules/prefect/engine/prefect.py
@@ -83,7 +83,12 @@ def _task_flow(*inner_args, **inner_kwargs):
 
     def _init_flow(self, flow: IsFlow, call_func: Callable) -> Any:
         assert isinstance(self._config, PrefectEngineConfig)
-        flow_kwargs = dict(name=flow.name,)
+        flow_kwargs = dict(
+            name=flow.name,
+            # persist_result=True,
+            result_storage='nird-minio',
+            result_storage_key=flow.name,
+            result_serializer='pickle')
         if flow.has_coroutine_func():
 
             @prefect_flow(**flow_kwargs)