[BEAM-10853] Merge pull request #12772: Cherrypick: Fixing copy name issue: Single name for all copies

[cherry-pick][BEAM-10853] Fixing copy name issue: Single name for all copies

Author: youngoli

sdks/python/apache_beam/io/gcp/bigquery_file_loads.py

@@ -70,7 +70,10 @@
 
 def _generate_job_name(job_name, job_type, step_name):
   return bigquery_tools.generate_bq_job_name(
-      job_name, step_name, job_type, random.randint(0, 1000))
+      job_name=job_name,
+      step_id=step_name,
+      job_type=job_type,
+      random=random.randint(0, 1000))
 
 
 def file_prefix_generator(
@@ -360,9 +363,9 @@ def process(self, element, job_name_prefix=None):
         job_name_prefix,
         _bq_uuid(
             '%s:%s.%s' % (
-                copy_to_reference.projectId,
-                copy_to_reference.datasetId,
-                copy_to_reference.tableId)))
+                copy_from_reference.projectId,
+                copy_from_reference.datasetId,
+                copy_from_reference.tableId)))
 
     _LOGGER.info(
         "Triggering copy job from %s to %s",

sdks/python/apache_beam/io/gcp/bigquery_test.py

@@ -1135,6 +1135,11 @@ def setUp(self):
   def test_avro_file_load(self):
     # Construct elements such that they can be written via Avro but not via
     # JSON. See BEAM-8841.
+    from apache_beam.io.gcp import bigquery_file_loads
+    old_max_files = bigquery_file_loads._MAXIMUM_SOURCE_URIS
+    old_max_file_size = bigquery_file_loads._DEFAULT_MAX_FILE_SIZE
+    bigquery_file_loads._MAXIMUM_SOURCE_URIS = 1
+    bigquery_file_loads._DEFAULT_MAX_FILE_SIZE = 100
     elements = [
         {
             'name': u'Negative infinity',
@@ -1194,6 +1199,8 @@ def test_avro_file_load(self):
               method='FILE_LOADS',
               temp_file_format=bigquery_tools.FileFormat.AVRO,
           ))
+    bigquery_file_loads._MAXIMUM_SOURCE_URIS = old_max_files
+    bigquery_file_loads._DEFAULT_MAX_FILE_SIZE = old_max_file_size
 
   def tearDown(self):
     request = bigquery.BigqueryDatasetsDeleteRequest(