Fina Silva-Santisteban03/30/2022, 6:52 PM
flow.set_dependencies( task=SnowflakeQuery, keyword_tasks=dict(query='''SELECT * FROM dummy_table;''' ) ) flow.set_dependencies( task=save_query_result_as_df, keyword_tasks=dict(result_set=SnowflakeQuery) )
currently only does a
. I’m confused about a few things: • I didn’t provide the
with any authentication. Why doesn’t it throw an error about that? • The print statement prints out
, which makes me think the snowflakequery task wasn’t run? If it wasn’t run it would at least explain why it didn’t throw an error 😅 but how can I make it run?
alex03/30/2022, 6:55 PM
task class to use within your flow. Something like this
snowflake_task = SnowflakeQuery() flow.set_dependencies( task=snowflake_task, keyword_tasks=dict(query='''SELECT * FROM dummy_table;''' ) )
Kevin Kho03/30/2022, 6:56 PM
Fina Silva-Santisteban03/30/2022, 6:58 PM
, which is not the most useful since I need the result set as a dataframe. 😓 I’ll need to set up and use the
List[List]: output of cursor.fetchall()
to get what I need. Can I submit this somewhere as a feature request??
Kevin Kho03/31/2022, 5:05 PM
alex03/31/2022, 5:20 PM