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}}""")
)