Rajvir Jhawar
08/03/2022, 2:55 PMfrom prefect import flow, get_run_logger
@flow(name="test", version="1.0beta")
def main():
logger = get_run_logger()
<http://logger.info|logger.info>(f"Hello World")
if __name__ == "__main__":
main()
Flow model details:
id=UUID('120dea46-79e8-4f42-99f0-7e300a2b3cb9') name='test' tags=[]
This is big blocker for me as I want to the create_flow_run
method, but it errors out after you give it a flow model without a version in it.
Any suggestion on what i am doing wrong here?Khuyen Tran
08/03/2022, 3:13 PMfrom prefect import flow, task
import pickle
from prefect.filesystems import LocalFileSystem
@task
def my_task():
a = [1, 2, 3]
local_file_system_block = LocalFileSystem.load("test")
save_path = f'{local_file_system_block.basepath}/a.pkl'
pickle.dump(a, open(save_path, 'wb'))
@flow(version="1")
def my_flow():
my_task()
if __name__ == "__main__":
my_flow()
I saw the version on the UI on the right panel when clicking the flow run. Can you check again if you see it?Rajvir Jhawar
08/03/2022, 3:29 PMKhuyen Tran
08/03/2022, 6:22 PMRajvir Jhawar
08/03/2022, 7:21 PMKhuyen Tran
08/03/2022, 7:44 PMcreate_flow_run
?Rajvir Jhawar
08/03/2022, 7:54 PMKhuyen Tran
08/03/2022, 7:56 PMRajvir Jhawar
08/03/2022, 8:30 PMKhuyen Tran
08/03/2022, 9:18 PMcreate_flow_run_from_deployment
since you can specify a name for a deployment. Maybe I don’t understand your use case here?Rajvir Jhawar
08/03/2022, 10:39 PM