leaf_engine_flows.config

Functions

`_get_checkpoint_serializer`(...)
`_get_pandas_serializer`(...)
`config_k8s`(→ prefect.run_configs.KubernetesRun)
`config_result`(...)
`config_result_file`(file_name, file_type)
`format_path`([checkpoint, file_name, file_type])

Module Contents

leaf_engine_flows.config._get_checkpoint_serializer() → leaf_engine_flows.serializer.LeafCheckpointSerializer

Return type:: leaf_engine_flows.serializer.LeafCheckpointSerializer

leaf_engine_flows.config._get_pandas_serializer() → prefect.engine.serializers.PandasSerializer

Return type:: prefect.engine.serializers.PandasSerializer

leaf_engine_flows.config.config_k8s() → prefect.run_configs.KubernetesRun

Return type:: prefect.run_configs.KubernetesRun

leaf_engine_flows.config.config_result(location=None, serializer=None) → prefect.engine.results.LocalResult | prefect.engine.results.S3Result

Return type:: Union[prefect.engine.results.LocalResult, prefect.engine.results.S3Result]

leaf_engine_flows.config.config_result_file(file_name, file_type)

leaf_engine_flows.config.format_path(checkpoint=False, file_name=None, file_type='csv', **kwargs)