fix define_schema for arrays of records

RealSelf · Oct 24, 2018 · a38c75d · a38c75d
1 parent 7923e29
commit a38c75d
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/target_bigquery.py b/target_bigquery.py
@@ -73,12 +73,16 @@ def define_schema(field, name):
         schema_type = field['type'][1]
     else:
         schema_type = field['type']
-    if schema_type == "array":
-        schema_type = field.get('items').get('type')
-        schema_mode = "REPEATED"
     if schema_type == "object":
         schema_type = "RECORD"
         schema_fields = tuple(build_schema(field))
+    if schema_type == "array":
+        schema_type = field.get('items').get('type')
+        schema_mode = "REPEATED"
+        if schema_type == "object":
+          schema_type = "RECORD"
+          schema_fields = tuple(build_schema(field.get('items')))
+
 
     if schema_type == "string":
         if "format" in field: