@mock.patch('airflow.providers.google.cloud.operators.bigquery.BigQueryHook')
def test_bigquery_operator_defaults(self, mock_hook, create_task_instance_of_operator):
    ti = create_task_instance_of_operator(BigQueryExecuteQueryOperator, dag_id=TEST_DAG_ID, task_id=TASK_ID, sql='Select * from test_table', schema_update_options=None)
    operator = ti.task
    operator.execute(MagicMock())
    mock_hook.return_value.run_query.assert_called_once_with(sql='Select * from test_table', destination_dataset_table=None, write_disposition='WRITE_EMPTY', allow_large_results=False, flatten_results=None, udf_config=None, maximum_billing_tier=None, maximum_bytes_billed=None, create_disposition='CREATE_IF_NEEDED', schema_update_options=None, query_params=None, labels=None, priority='INTERACTIVE', time_partitioning=None, api_resource_configs=None, cluster_fields=None, encryption_configuration=None)
    assert isinstance(operator.sql, str)
    ti.render_templates()
    assert isinstance(ti.task.sql, str)
@mock.patch('airflow.providers.google.cloud.operators.bigquery.BigQueryHook')
def test_bigquery_operator_defaults(self, mock_hook, create_task_instance_of_operator):
    ti = create_task_instance_of_operator(BigQueryExecuteQueryOperator, dag_id=TEST_DAG_ID, task_id=TASK_ID, sql='Select * from test_table', schema_update_options=None)
    operator = ti.task
    operator.execute(MagicMock())
    mock_hook.return_value.run_query.assert_called_once_with(sql='Select * from test_table', destination_dataset_table=None, write_disposition='WRITE_EMPTY', allow_large_results=False, flatten_results=None, udf_config=None, maximum_billing_tier=None, maximum_bytes_billed=None, create_disposition='CREATE_IF_NEEDED', schema_update_options=None, query_params=None, labels=None, priority='INTERACTIVE', time_partitioning=None, api_resource_configs=None, cluster_fields=None, encryption_configuration=None)
    assert isinstance(operator.sql, str)
    ti.render_templates()
    assert isinstance(ti.task.sql, str)