@mock.patch('airflow.providers.google.cloud.operators.bigquery.BigQueryHook')
def test_bigquery_operator_extra_link_when_multiple_query(self, mock_hook, create_task_instance_of_operator):
    ti = create_task_instance_of_operator(BigQueryExecuteQueryOperator, dag_id=TEST_DAG_ID, execution_date=DEFAULT_DATE, task_id=TASK_ID, sql=['SELECT * FROM test_table', 'SELECT * FROM test_table2'])
    bigquery_task = ti.task
    job_id = ['123', '45']
    ti.xcom_push(key='job_id', value=job_id)
    assert ({'BigQuery Console #1', 'BigQuery Console #2'} == bigquery_task.operator_extra_link_dict.keys())
    assert ('https://console.cloud.google.com/bigquery?j=123' == bigquery_task.get_extra_links(ti, 'BigQuery Console #1'))
    assert ('https://console.cloud.google.com/bigquery?j=45' == bigquery_task.get_extra_links(ti, 'BigQuery Console #2'))
@mock.patch('airflow.providers.google.cloud.operators.bigquery.BigQueryHook')
def test_bigquery_operator_extra_link_when_multiple_query(self, mock_hook, create_task_instance_of_operator):
    ti = create_task_instance_of_operator(BigQueryExecuteQueryOperator, dag_id=TEST_DAG_ID, execution_date=DEFAULT_DATE, task_id=TASK_ID, sql=['SELECT * FROM test_table', 'SELECT * FROM test_table2'])
    bigquery_task = ti.task
    job_id = ['123', '45']
    ti.xcom_push(key='job_id', value=job_id)
    assert ({'BigQuery Console #1', 'BigQuery Console #2'} == bigquery_task.operator_extra_link_dict.keys())
    assert ('https://console.cloud.google.com/bigquery?j=123' == bigquery_task.get_extra_links(ti, 'BigQuery Console #1'))
    assert ('https://console.cloud.google.com/bigquery?j=45' == bigquery_task.get_extra_links(ti, 'BigQuery Console #2'))