Jason Wiener
03/18/2024, 10:12 PMMarvin
03/18/2024, 10:13 PMJason Wiener
03/18/2024, 10:15 PMMarvin
03/18/2024, 10:15 PMNate
03/18/2024, 10:43 PMHow do I specify mandatory parameters for a flow?by just omitting default values like
def foo(x: str)
etcNate
03/18/2024, 10:43 PMJason Wiener
03/19/2024, 2:56 PM@flow(retries=0)
def load_contacts_to_van(source_data_sql: str, van_api_secret_name: str):
logger = get_run_logger()
....
Nate
03/19/2024, 2:57 PMJason Wiener
03/19/2024, 3:16 PMprefect deploy
wizard, which created this artifact in prefect.yaml:
- name: load to van demo
version:
tags: []
description:
entrypoint: organizing\load-van.py:load_contacts_to_van
parameters: {}
work_pool:
name: legacy
work_queue_name:
job_variables: {}
schedules: []
Nate
03/19/2024, 3:16 PMNate
03/19/2024, 3:24 PMprefect deployment inspect your-flow/your-deployment
?Jason Wiener
03/19/2024, 7:54 PM'parameter_openapi_schema': {
'type': 'object',
'title': 'Parameters',
'required': ['source_data_sql', 'van_api_secret_name'],
'properties': {'source_data_sql': {'type': 'string', 'title': 'source_data_sql', 'position': 0}, 'van_api_secret_name': {'type': 'string', 'title': 'van_api_secret_name', 'position': 1}}
},
Nate
03/19/2024, 8:00 PMload_contacts_to_van(source_data_sql: str, van_api_secret_name: str)
)
• form has (Optional)
hanging around for those fieldsCraig Harshbarger
03/19/2024, 10:22 PMJason Wiener
03/19/2024, 10:35 PMCraig Harshbarger
03/20/2024, 1:07 AM