diff --git a/packages/pipe-vms-ingestion/assets/feeds/reported_vessel_info.schema.json b/packages/pipe-vms-ingestion/assets/feeds/reported_vessel_info.schema.json index e908566..ec73bc2 100644 --- a/packages/pipe-vms-ingestion/assets/feeds/reported_vessel_info.schema.json +++ b/packages/pipe-vms-ingestion/assets/feeds/reported_vessel_info.schema.json @@ -1,18 +1,18 @@ [ { - "mode": "NULLABLE", + "mode": "REQUIRED", "name": "ssvid", "type": "STRING", "description": "Unique Id combining source_tenant and source_ssvid" }, { - "mode": "NULLABLE", + "mode": "REQUIRED", "name": "source_tenant", "type": "STRING", "description": "The proprietary of the data (Eg: country)" }, { - "mode": "NULLABLE", + "mode": "REQUIRED", "name": "timestamp", "type": "TIMESTAMP", "description": "This is the unix timestamp for the time the message was received by the original receiver. You should use this as the effective timestamp for the message" @@ -78,15 +78,9 @@ "description": "The width of the boat in meters" }, { - "mode": "NULLABLE", - "name": "received_at", - "type": "TIMESTAMP", - "description": "The exact moment when this record was read/received in our platform (email, file, api call, etc..) from the source." - }, - { - "mode": "NULLABLE", + "mode": "REQUIRED", "name": "updated_at", "type": "TIMESTAMP", - "description": "The exact moment this record was ingested by us (GFW) this is when the raw record is stored in our raw BQ tables" + "description": "The exact moment this record was updated by us (GFW) this is when the vessel info record is stored in our BQ tables" } ]