jobs/dap-collector-ppa-prod/dap_collector_ppa_prod/main.py [39:47]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    bigquery.SchemaField("collection_time", "TIMESTAMP", mode="REQUIRED"),
    bigquery.SchemaField("collection_duration", "FLOAT", mode="REQUIRED"),
    bigquery.SchemaField("task_id", "STRING", mode="REQUIRED"),
    bigquery.SchemaField("metric_type", "STRING", mode="REQUIRED"),
    bigquery.SchemaField("slot_start", "TIMESTAMP", mode="REQUIRED"),
    bigquery.SchemaField("report_count", "INTEGER"),
    bigquery.SchemaField("error", "STRING"),
    bigquery.SchemaField("value", "INTEGER", mode="REPEATED"),
]
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



jobs/dap-collector/dap_collector/main.py [171:179]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        bigquery.SchemaField("collection_time", "TIMESTAMP", mode="REQUIRED"),
        bigquery.SchemaField("collection_duration", "FLOAT", mode="REQUIRED"),
        bigquery.SchemaField("task_id", "STRING", mode="REQUIRED"),
        bigquery.SchemaField("metric_type", "STRING", mode="REQUIRED"),
        bigquery.SchemaField("slot_start", "TIMESTAMP", mode="REQUIRED"),
        bigquery.SchemaField("report_count", "INTEGER"),
        bigquery.SchemaField("error", "STRING"),
        bigquery.SchemaField("value", "INTEGER", mode="REPEATED"),
    ]
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -