If I have a flow like :

with Flow("flow", run_config=RUN_CONFIG, storage=STORAGE) as flow:
  json_data = get_json_data(
    url, query, headers,
    task_args={"name": "Getting Flow Data"}
  )

How can I then access json_data as a python object, rather than a FunctionTask object?

You have to pass it in a task and access it inside a task

Could you clarify further? Let’s say the output of get_json_data() is a dataframe and I wanted to do: 1. get the first row of the df as a variable a.

first_row = json_data[0,]

2. pass dataframe into the next task a.

processed_df = process_dataframe(json_data, task_args={"name": "Processing df"})

Yeah so number 1 needs to happen inside a task because

json_data

is of type Task until execution time of the flow. The

json_data[0,]

syntax accesses the Task because it runs during build time, not run time. So you need to put this logic inside a Task so that it will defer to run time instead of build time. Does that make sense?

Ah I see! I shall test it out, thanks for the quick support

Yeah exactly. Logs in the flow block are executed during build time, not run time