https://flyte.org logo
#ask-the-community
Title
# ask-the-community
a

aklalwani100

03/31/2024, 6:56 PM
hey all, is there any way to pass the database url and output schema through variable to the sqlalchmey task ql_task=SQLAlchemyTask( "fetch_task", query_template=""" select * from {{.inputs.schema_name}}.{{.inputs.table_name}} where {{.inputs.cursor_name}} >= {{ .inputs.cursor_value }} limit {{ .inputs.limit }} offset {{.inputs.offset}} """, inputs=kwtypes(limit=int, offset=int,cursor_name=str,cursor_value=int,uri=str), # output_schema_type=convert_pandera_schema_to_flyte(SampleSchema), task_config=SQLAlchemyConfig(uri="""{{.inputs.uri}}""") )
2 Views