@mock.patch('airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.insert_job')
def test_run_copy_with_kms(self, mock_insert):
    encryption_configuration = {'kms_key_name': 'projects/p/locations/l/keyRings/k/cryptoKeys/c'}
    self.hook.run_copy(source_project_dataset_tables='p.d.st', destination_project_dataset_table='p.d.dt', encryption_configuration=encryption_configuration)
    (_, kwargs) = mock_insert.call_args
    assert (kwargs['configuration']['copy']['destinationEncryptionConfiguration'] is encryption_configuration)
@mock.patch('airflow.providers.google.cloud.hooks.bigquery.BigQueryHook.insert_job')
def test_run_copy_with_kms(self, mock_insert):
    encryption_configuration = {'kms_key_name': 'projects/p/locations/l/keyRings/k/cryptoKeys/c'}
    self.hook.run_copy(source_project_dataset_tables='p.d.st', destination_project_dataset_table='p.d.dt', encryption_configuration=encryption_configuration)
    (_, kwargs) = mock_insert.call_args
    assert (kwargs['configuration']['copy']['destinationEncryptionConfiguration'] is encryption_configuration)