title: Creating dynamic tasks in airflow (in composer) based on bigquery response
body: <p>I am trying to create a airflow DAG which generates task depending on the response from server.</p>
  
  <p>Here is my approach :</p>
  
  <p>getlist of tables from bigquery -> loop through the list and create tasks</p>
  
  <p>This is my latest code and I have tried all possible code found in stack overflow. Nothing seems to work. What am I doing wrong?</p>
  
  <pre><code>with models.DAG(dag_id="xt", default_args=default_args, schedule_interval="0 1 * * *", catchup=True) as dag:
  tables = get_tables_from_bq()
  
      bridge = DummyOperator(
          task_id='bridge',
          dag=dag
      )
  
  
      for t in tables:
          sql = ("SELECT * FROM `{project}.{dataset}.{table}` LIMIT 5;".format(
                  project=project, dataset=dataset, table=t))
  
      materialize_t = BigQueryOperator(bql=sql,
                                       destination_dataset_table=dataset+'.' + table_prefix + t,
                                       task_id = 'x_' + t,
                                       bigquery_conn_id = 'bigquery_default',
                                       use_legacy_sql = False,
                                       write_disposition = 'WRITE_APPEND',
                                       create_disposition = 'CREATE_IF_NEEDED',
                                       query_params = {},
                                       allow_large_results = True,
                                       dag = dag)
  
  bridge &gt;&gt; materialize_t
  </code></pre>
  
  <p>Even the run option is not showing with this code. I tried multiple codes and finally reached here but still no luck. Any help???</p>
  
  <p><a href="https://i.stack.imgur.com/rxgye.png" rel="nofollow noreferrer"><img src="https://i.stack.imgur.com/rxgye.png" alt="enter image description here"></a></p>