Schema Info
Schema Name: sfdl_prod_postgres.keplernormies_lead_fact
- created: 2019-10-31 03:17:54
- disabled: False
- format: raw
- id: 754
- is_partitioned: False
- is_schema_datatyped: True
- name:
{ "database": "sfdl_prod_postgres", "table": "keplernormies_lead_fact" } - type: postgres
Schema Versions: 15
-
Version 1717512
- created: 2026-04-17 00:56:42
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_prod_postgres`", "DROP TABLE IF EXISTS `sfdl_prod_postgres.keplernormies_lead_fact`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_postgres.keplernormies_lead_fact`\n(\n `lead_fact_id` int , `provider_id` string , `provider` string , `status` string , `source_name` string , `company_dim_id` int , `facility_dim_id` int , `unit_dim_id` int , `tenant_dim_id` int , `date_dim_id` int , `cancelled_on_dim_id` int , `reserved_on_dim_id` int , `moved_in_on_dim_id` int , `source_dim_id` int , `migrated_on` string , `category_name` string , `received_epoch` bigint , `desired_move_in_dim_id` int , `next_action_at_dim_id` int , `next_lead_action` string , `wait_list` string , `wait_list_available` string , `quoted_rate` decimal , `deleted` string , `deleted_on_date_dim_id` int , `origination` string , `is_upgrade` string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'\n WITH SERDEPROPERTIES ( 'field.delim' = '\u0001', 'quote.delim' = '\"', 'escape.delim' = '\\\\')\nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-17/1776405369'\nTBLPROPERTIES ('skip.header.line.count' = '1')", "MSCK REPAIR TABLE sfdl_prod_postgres.keplernormies_lead_fact" ] - hive_path: s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-17/1776405369
- id: 1717512
- processed: 1
- raw_data:
{ "cancelled_on_dim_id": 10, "category_name": 15, "company_dim_id": 5, "date_dim_id": 9, "deleted": 23, "deleted_on_date_dim_id": 24, "desired_move_in_dim_id": 17, "facility_dim_id": 6, "is_upgrade": 26, "lead_fact_id": 0, "migrated_on": 14, "moved_in_on_dim_id": 12, "next_action_at_dim_id": 18, "next_lead_action": 19, "origination": 25, "provider": 2, "provider_id": 1, "quoted_rate": 22, "received_epoch": 16, "reserved_on_dim_id": 11, "source_dim_id": 13, "source_name": 4, "status": 3, "tenant_dim_id": 8, "unit_dim_id": 7, "wait_list": 20, "wait_list_available": 21 } - schema_attributes:
{ "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" } - schema_name_id: 754
- schema_scan_id: 162164096
- updated: 2026-04-17 00:56:56
-
Version 1716273
- created: 2026-04-16 01:04:55
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_prod_postgres`", "DROP TABLE IF EXISTS `sfdl_prod_postgres.keplernormies_lead_fact`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_postgres.keplernormies_lead_fact`\n(\n `lead_fact_id` int , `provider_id` string , `provider` string , `status` string , `source_name` string , `company_dim_id` int , `facility_dim_id` int , `unit_dim_id` int , `tenant_dim_id` int , `date_dim_id` int , `cancelled_on_dim_id` int , `reserved_on_dim_id` int , `moved_in_on_dim_id` int , `source_dim_id` int , `migrated_on` string , `category_name` string , `received_epoch` bigint , `desired_move_in_dim_id` int , `next_action_at_dim_id` int , `next_lead_action` string , `wait_list` string , `wait_list_available` string , `quoted_rate` decimal , `deleted` string , `deleted_on_date_dim_id` int , `origination` string , `is_upgrade` string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'\n WITH SERDEPROPERTIES ( 'field.delim' = '\u0001', 'quote.delim' = '\"', 'escape.delim' = '\\\\')\nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-16/1776319477'\nTBLPROPERTIES ('skip.header.line.count' = '1')", "MSCK REPAIR TABLE sfdl_prod_postgres.keplernormies_lead_fact" ] - hive_path: s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-16/1776319477
- id: 1716273
- processed: 1
- raw_data:
{ "cancelled_on_dim_id": 10, "category_name": 15, "company_dim_id": 5, "date_dim_id": 9, "deleted": 23, "deleted_on_date_dim_id": 24, "desired_move_in_dim_id": 17, "facility_dim_id": 6, "is_upgrade": 26, "lead_fact_id": 0, "migrated_on": 14, "moved_in_on_dim_id": 12, "next_action_at_dim_id": 18, "next_lead_action": 19, "origination": 25, "provider": 2, "provider_id": 1, "quoted_rate": 22, "received_epoch": 16, "reserved_on_dim_id": 11, "source_dim_id": 13, "source_name": 4, "status": 3, "tenant_dim_id": 8, "unit_dim_id": 7, "wait_list": 20, "wait_list_available": 21 } - schema_attributes:
{ "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" } - schema_name_id: 754
- schema_scan_id: 162109255
- updated: 2026-04-16 01:05:08
-
Version 1715088
- created: 2026-04-15 01:08:39
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_prod_postgres`", "DROP TABLE IF EXISTS `sfdl_prod_postgres.keplernormies_lead_fact`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_postgres.keplernormies_lead_fact`\n(\n `lead_fact_id` int , `provider_id` string , `provider` string , `status` string , `source_name` string , `company_dim_id` int , `facility_dim_id` int , `unit_dim_id` int , `tenant_dim_id` int , `date_dim_id` int , `cancelled_on_dim_id` int , `reserved_on_dim_id` int , `moved_in_on_dim_id` int , `source_dim_id` int , `migrated_on` string , `category_name` string , `received_epoch` bigint , `desired_move_in_dim_id` int , `next_action_at_dim_id` int , `next_lead_action` string , `wait_list` string , `wait_list_available` string , `quoted_rate` decimal , `deleted` string , `deleted_on_date_dim_id` int , `origination` string , `is_upgrade` string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'\n WITH SERDEPROPERTIES ( 'field.delim' = '\u0001', 'quote.delim' = '\"', 'escape.delim' = '\\\\')\nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-15/1776233302'\nTBLPROPERTIES ('skip.header.line.count' = '1')", "MSCK REPAIR TABLE sfdl_prod_postgres.keplernormies_lead_fact" ] - hive_path: s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-15/1776233302
- id: 1715088
- processed: 1
- raw_data:
{ "cancelled_on_dim_id": 10, "category_name": 15, "company_dim_id": 5, "date_dim_id": 9, "deleted": 23, "deleted_on_date_dim_id": 24, "desired_move_in_dim_id": 17, "facility_dim_id": 6, "is_upgrade": 26, "lead_fact_id": 0, "migrated_on": 14, "moved_in_on_dim_id": 12, "next_action_at_dim_id": 18, "next_lead_action": 19, "origination": 25, "provider": 2, "provider_id": 1, "quoted_rate": 22, "received_epoch": 16, "reserved_on_dim_id": 11, "source_dim_id": 13, "source_name": 4, "status": 3, "tenant_dim_id": 8, "unit_dim_id": 7, "wait_list": 20, "wait_list_available": 21 } - schema_attributes:
{ "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" } - schema_name_id: 754
- schema_scan_id: 162053415
- updated: 2026-04-15 01:08:52
-
Version 1713882
- created: 2026-04-14 01:02:33
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_prod_postgres`", "DROP TABLE IF EXISTS `sfdl_prod_postgres.keplernormies_lead_fact`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_postgres.keplernormies_lead_fact`\n(\n `lead_fact_id` int , `provider_id` string , `provider` string , `status` string , `source_name` string , `company_dim_id` int , `facility_dim_id` int , `unit_dim_id` int , `tenant_dim_id` int , `date_dim_id` int , `cancelled_on_dim_id` int , `reserved_on_dim_id` int , `moved_in_on_dim_id` int , `source_dim_id` int , `migrated_on` string , `category_name` string , `received_epoch` bigint , `desired_move_in_dim_id` int , `next_action_at_dim_id` int , `next_lead_action` string , `wait_list` string , `wait_list_available` string , `quoted_rate` decimal , `deleted` string , `deleted_on_date_dim_id` int , `origination` string , `is_upgrade` string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'\n WITH SERDEPROPERTIES ( 'field.delim' = '\u0001', 'quote.delim' = '\"', 'escape.delim' = '\\\\')\nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-14/1776146527'\nTBLPROPERTIES ('skip.header.line.count' = '1')", "MSCK REPAIR TABLE sfdl_prod_postgres.keplernormies_lead_fact" ] - hive_path: s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-14/1776146527
- id: 1713882
- processed: 1
- raw_data:
{ "cancelled_on_dim_id": 10, "category_name": 15, "company_dim_id": 5, "date_dim_id": 9, "deleted": 23, "deleted_on_date_dim_id": 24, "desired_move_in_dim_id": 17, "facility_dim_id": 6, "is_upgrade": 26, "lead_fact_id": 0, "migrated_on": 14, "moved_in_on_dim_id": 12, "next_action_at_dim_id": 18, "next_lead_action": 19, "origination": 25, "provider": 2, "provider_id": 1, "quoted_rate": 22, "received_epoch": 16, "reserved_on_dim_id": 11, "source_dim_id": 13, "source_name": 4, "status": 3, "tenant_dim_id": 8, "unit_dim_id": 7, "wait_list": 20, "wait_list_available": 21 } - schema_attributes:
{ "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" } - schema_name_id: 754
- schema_scan_id: 161997587
- updated: 2026-04-14 01:02:44
-
Version 1712658
- created: 2026-04-13 01:04:58
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_prod_postgres`", "DROP TABLE IF EXISTS `sfdl_prod_postgres.keplernormies_lead_fact`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_postgres.keplernormies_lead_fact`\n(\n `lead_fact_id` int , `provider_id` string , `provider` string , `status` string , `source_name` string , `company_dim_id` int , `facility_dim_id` int , `unit_dim_id` int , `tenant_dim_id` int , `date_dim_id` int , `cancelled_on_dim_id` int , `reserved_on_dim_id` int , `moved_in_on_dim_id` int , `source_dim_id` int , `migrated_on` string , `category_name` string , `received_epoch` bigint , `desired_move_in_dim_id` int , `next_action_at_dim_id` int , `next_lead_action` string , `wait_list` string , `wait_list_available` string , `quoted_rate` decimal , `deleted` string , `deleted_on_date_dim_id` int , `origination` string , `is_upgrade` string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'\n WITH SERDEPROPERTIES ( 'field.delim' = '\u0001', 'quote.delim' = '\"', 'escape.delim' = '\\\\')\nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-13/1776060275'\nTBLPROPERTIES ('skip.header.line.count' = '1')", "MSCK REPAIR TABLE sfdl_prod_postgres.keplernormies_lead_fact" ] - hive_path: s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-13/1776060275
- id: 1712658
- processed: 1
- raw_data:
{ "cancelled_on_dim_id": 10, "category_name": 15, "company_dim_id": 5, "date_dim_id": 9, "deleted": 23, "deleted_on_date_dim_id": 24, "desired_move_in_dim_id": 17, "facility_dim_id": 6, "is_upgrade": 26, "lead_fact_id": 0, "migrated_on": 14, "moved_in_on_dim_id": 12, "next_action_at_dim_id": 18, "next_lead_action": 19, "origination": 25, "provider": 2, "provider_id": 1, "quoted_rate": 22, "received_epoch": 16, "reserved_on_dim_id": 11, "source_dim_id": 13, "source_name": 4, "status": 3, "tenant_dim_id": 8, "unit_dim_id": 7, "wait_list": 20, "wait_list_available": 21 } - schema_attributes:
{ "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" } - schema_name_id: 754
- schema_scan_id: 161940056
- updated: 2026-04-13 01:05:09
-
Version 1711451
- created: 2026-04-12 01:02:43
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_prod_postgres`", "DROP TABLE IF EXISTS `sfdl_prod_postgres.keplernormies_lead_fact`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_postgres.keplernormies_lead_fact`\n(\n `lead_fact_id` int , `provider_id` string , `provider` string , `status` string , `source_name` string , `company_dim_id` int , `facility_dim_id` int , `unit_dim_id` int , `tenant_dim_id` int , `date_dim_id` int , `cancelled_on_dim_id` int , `reserved_on_dim_id` int , `moved_in_on_dim_id` int , `source_dim_id` int , `migrated_on` string , `category_name` string , `received_epoch` bigint , `desired_move_in_dim_id` int , `next_action_at_dim_id` int , `next_lead_action` string , `wait_list` string , `wait_list_available` string , `quoted_rate` decimal , `deleted` string , `deleted_on_date_dim_id` int , `origination` string , `is_upgrade` string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'\n WITH SERDEPROPERTIES ( 'field.delim' = '\u0001', 'quote.delim' = '\"', 'escape.delim' = '\\\\')\nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-12/1775973540'\nTBLPROPERTIES ('skip.header.line.count' = '1')", "MSCK REPAIR TABLE sfdl_prod_postgres.keplernormies_lead_fact" ] - hive_path: s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-12/1775973540
- id: 1711451
- processed: 1
- raw_data:
{ "cancelled_on_dim_id": 10, "category_name": 15, "company_dim_id": 5, "date_dim_id": 9, "deleted": 23, "deleted_on_date_dim_id": 24, "desired_move_in_dim_id": 17, "facility_dim_id": 6, "is_upgrade": 26, "lead_fact_id": 0, "migrated_on": 14, "moved_in_on_dim_id": 12, "next_action_at_dim_id": 18, "next_lead_action": 19, "origination": 25, "provider": 2, "provider_id": 1, "quoted_rate": 22, "received_epoch": 16, "reserved_on_dim_id": 11, "source_dim_id": 13, "source_name": 4, "status": 3, "tenant_dim_id": 8, "unit_dim_id": 7, "wait_list": 20, "wait_list_available": 21 } - schema_attributes:
{ "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" } - schema_name_id: 754
- schema_scan_id: 161890378
- updated: 2026-04-12 01:02:57
-
Version 1710248
- created: 2026-04-11 01:03:19
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_prod_postgres`", "DROP TABLE IF EXISTS `sfdl_prod_postgres.keplernormies_lead_fact`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_postgres.keplernormies_lead_fact`\n(\n `lead_fact_id` int , `provider_id` string , `provider` string , `status` string , `source_name` string , `company_dim_id` int , `facility_dim_id` int , `unit_dim_id` int , `tenant_dim_id` int , `date_dim_id` int , `cancelled_on_dim_id` int , `reserved_on_dim_id` int , `moved_in_on_dim_id` int , `source_dim_id` int , `migrated_on` string , `category_name` string , `received_epoch` bigint , `desired_move_in_dim_id` int , `next_action_at_dim_id` int , `next_lead_action` string , `wait_list` string , `wait_list_available` string , `quoted_rate` decimal , `deleted` string , `deleted_on_date_dim_id` int , `origination` string , `is_upgrade` string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'\n WITH SERDEPROPERTIES ( 'field.delim' = '\u0001', 'quote.delim' = '\"', 'escape.delim' = '\\\\')\nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-11/1775887381'\nTBLPROPERTIES ('skip.header.line.count' = '1')", "MSCK REPAIR TABLE sfdl_prod_postgres.keplernormies_lead_fact" ] - hive_path: s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-11/1775887381
- id: 1710248
- processed: 1
- raw_data:
{ "cancelled_on_dim_id": 10, "category_name": 15, "company_dim_id": 5, "date_dim_id": 9, "deleted": 23, "deleted_on_date_dim_id": 24, "desired_move_in_dim_id": 17, "facility_dim_id": 6, "is_upgrade": 26, "lead_fact_id": 0, "migrated_on": 14, "moved_in_on_dim_id": 12, "next_action_at_dim_id": 18, "next_lead_action": 19, "origination": 25, "provider": 2, "provider_id": 1, "quoted_rate": 22, "received_epoch": 16, "reserved_on_dim_id": 11, "source_dim_id": 13, "source_name": 4, "status": 3, "tenant_dim_id": 8, "unit_dim_id": 7, "wait_list": 20, "wait_list_available": 21 } - schema_attributes:
{ "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" } - schema_name_id: 754
- schema_scan_id: 161838639
- updated: 2026-04-11 01:03:30
-
Version 1709107
- created: 2026-04-10 01:02:58
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_prod_postgres`", "DROP TABLE IF EXISTS `sfdl_prod_postgres.keplernormies_lead_fact`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_postgres.keplernormies_lead_fact`\n(\n `lead_fact_id` int , `provider_id` string , `provider` string , `status` string , `source_name` string , `company_dim_id` int , `facility_dim_id` int , `unit_dim_id` int , `tenant_dim_id` int , `date_dim_id` int , `cancelled_on_dim_id` int , `reserved_on_dim_id` int , `moved_in_on_dim_id` int , `source_dim_id` int , `migrated_on` string , `category_name` string , `received_epoch` bigint , `desired_move_in_dim_id` int , `next_action_at_dim_id` int , `next_lead_action` string , `wait_list` string , `wait_list_available` string , `quoted_rate` decimal , `deleted` string , `deleted_on_date_dim_id` int , `origination` string , `is_upgrade` string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'\n WITH SERDEPROPERTIES ( 'field.delim' = '\u0001', 'quote.delim' = '\"', 'escape.delim' = '\\\\')\nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-10/1775800910'\nTBLPROPERTIES ('skip.header.line.count' = '1')", "MSCK REPAIR TABLE sfdl_prod_postgres.keplernormies_lead_fact" ] - hive_path: s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-10/1775800910
- id: 1709107
- processed: 1
- raw_data:
{ "cancelled_on_dim_id": 10, "category_name": 15, "company_dim_id": 5, "date_dim_id": 9, "deleted": 23, "deleted_on_date_dim_id": 24, "desired_move_in_dim_id": 17, "facility_dim_id": 6, "is_upgrade": 26, "lead_fact_id": 0, "migrated_on": 14, "moved_in_on_dim_id": 12, "next_action_at_dim_id": 18, "next_lead_action": 19, "origination": 25, "provider": 2, "provider_id": 1, "quoted_rate": 22, "received_epoch": 16, "reserved_on_dim_id": 11, "source_dim_id": 13, "source_name": 4, "status": 3, "tenant_dim_id": 8, "unit_dim_id": 7, "wait_list": 20, "wait_list_available": 21 } - schema_attributes:
{ "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" } - schema_name_id: 754
- schema_scan_id: 161783071
- updated: 2026-04-10 01:03:09
-
Version 1707956
- created: 2026-04-09 00:55:16
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_prod_postgres`", "DROP TABLE IF EXISTS `sfdl_prod_postgres.keplernormies_lead_fact`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_postgres.keplernormies_lead_fact`\n(\n `lead_fact_id` int , `provider_id` string , `provider` string , `status` string , `source_name` string , `company_dim_id` int , `facility_dim_id` int , `unit_dim_id` int , `tenant_dim_id` int , `date_dim_id` int , `cancelled_on_dim_id` int , `reserved_on_dim_id` int , `moved_in_on_dim_id` int , `source_dim_id` int , `migrated_on` string , `category_name` string , `received_epoch` bigint , `desired_move_in_dim_id` int , `next_action_at_dim_id` int , `next_lead_action` string , `wait_list` string , `wait_list_available` string , `quoted_rate` decimal , `deleted` string , `deleted_on_date_dim_id` int , `origination` string , `is_upgrade` string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'\n WITH SERDEPROPERTIES ( 'field.delim' = '\u0001', 'quote.delim' = '\"', 'escape.delim' = '\\\\')\nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-09/1775714096'\nTBLPROPERTIES ('skip.header.line.count' = '1')", "MSCK REPAIR TABLE sfdl_prod_postgres.keplernormies_lead_fact" ] - hive_path: s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-09/1775714096
- id: 1707956
- processed: 1
- raw_data:
{ "cancelled_on_dim_id": 10, "category_name": 15, "company_dim_id": 5, "date_dim_id": 9, "deleted": 23, "deleted_on_date_dim_id": 24, "desired_move_in_dim_id": 17, "facility_dim_id": 6, "is_upgrade": 26, "lead_fact_id": 0, "migrated_on": 14, "moved_in_on_dim_id": 12, "next_action_at_dim_id": 18, "next_lead_action": 19, "origination": 25, "provider": 2, "provider_id": 1, "quoted_rate": 22, "received_epoch": 16, "reserved_on_dim_id": 11, "source_dim_id": 13, "source_name": 4, "status": 3, "tenant_dim_id": 8, "unit_dim_id": 7, "wait_list": 20, "wait_list_available": 21 } - schema_attributes:
{ "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" } - schema_name_id: 754
- schema_scan_id: 161726789
- updated: 2026-04-09 00:55:27
-
Version 1706755
- created: 2026-04-08 01:09:41
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_prod_postgres`", "DROP TABLE IF EXISTS `sfdl_prod_postgres.keplernormies_lead_fact`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_postgres.keplernormies_lead_fact`\n(\n `lead_fact_id` int , `provider_id` string , `provider` string , `status` string , `source_name` string , `company_dim_id` int , `facility_dim_id` int , `unit_dim_id` int , `tenant_dim_id` int , `date_dim_id` int , `cancelled_on_dim_id` int , `reserved_on_dim_id` int , `moved_in_on_dim_id` int , `source_dim_id` int , `migrated_on` string , `category_name` string , `received_epoch` bigint , `desired_move_in_dim_id` int , `next_action_at_dim_id` int , `next_lead_action` string , `wait_list` string , `wait_list_available` string , `quoted_rate` decimal , `deleted` string , `deleted_on_date_dim_id` int , `origination` string , `is_upgrade` string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'\n WITH SERDEPROPERTIES ( 'field.delim' = '\u0001', 'quote.delim' = '\"', 'escape.delim' = '\\\\')\nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-08/1775628564'\nTBLPROPERTIES ('skip.header.line.count' = '1')", "MSCK REPAIR TABLE sfdl_prod_postgres.keplernormies_lead_fact" ] - hive_path: s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-08/1775628564
- id: 1706755
- processed: 1
- raw_data:
{ "cancelled_on_dim_id": 10, "category_name": 15, "company_dim_id": 5, "date_dim_id": 9, "deleted": 23, "deleted_on_date_dim_id": 24, "desired_move_in_dim_id": 17, "facility_dim_id": 6, "is_upgrade": 26, "lead_fact_id": 0, "migrated_on": 14, "moved_in_on_dim_id": 12, "next_action_at_dim_id": 18, "next_lead_action": 19, "origination": 25, "provider": 2, "provider_id": 1, "quoted_rate": 22, "received_epoch": 16, "reserved_on_dim_id": 11, "source_dim_id": 13, "source_name": 4, "status": 3, "tenant_dim_id": 8, "unit_dim_id": 7, "wait_list": 20, "wait_list_available": 21 } - schema_attributes:
{ "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" } - schema_name_id: 754
- schema_scan_id: 161672803
- updated: 2026-04-08 01:09:55
-
Version 1705565
- created: 2026-04-07 01:03:14
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_prod_postgres`", "DROP TABLE IF EXISTS `sfdl_prod_postgres.keplernormies_lead_fact`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_postgres.keplernormies_lead_fact`\n(\n `lead_fact_id` int , `provider_id` string , `provider` string , `status` string , `source_name` string , `company_dim_id` int , `facility_dim_id` int , `unit_dim_id` int , `tenant_dim_id` int , `date_dim_id` int , `cancelled_on_dim_id` int , `reserved_on_dim_id` int , `moved_in_on_dim_id` int , `source_dim_id` int , `migrated_on` string , `category_name` string , `received_epoch` bigint , `desired_move_in_dim_id` int , `next_action_at_dim_id` int , `next_lead_action` string , `wait_list` string , `wait_list_available` string , `quoted_rate` decimal , `deleted` string , `deleted_on_date_dim_id` int , `origination` string , `is_upgrade` string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'\n WITH SERDEPROPERTIES ( 'field.delim' = '\u0001', 'quote.delim' = '\"', 'escape.delim' = '\\\\')\nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-07/1775541775'\nTBLPROPERTIES ('skip.header.line.count' = '1')", "MSCK REPAIR TABLE sfdl_prod_postgres.keplernormies_lead_fact" ] - hive_path: s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-07/1775541775
- id: 1705565
- processed: 1
- raw_data:
{ "cancelled_on_dim_id": 10, "category_name": 15, "company_dim_id": 5, "date_dim_id": 9, "deleted": 23, "deleted_on_date_dim_id": 24, "desired_move_in_dim_id": 17, "facility_dim_id": 6, "is_upgrade": 26, "lead_fact_id": 0, "migrated_on": 14, "moved_in_on_dim_id": 12, "next_action_at_dim_id": 18, "next_lead_action": 19, "origination": 25, "provider": 2, "provider_id": 1, "quoted_rate": 22, "received_epoch": 16, "reserved_on_dim_id": 11, "source_dim_id": 13, "source_name": 4, "status": 3, "tenant_dim_id": 8, "unit_dim_id": 7, "wait_list": 20, "wait_list_available": 21 } - schema_attributes:
{ "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" } - schema_name_id: 754
- schema_scan_id: 161616693
- updated: 2026-04-07 01:03:28
-
Version 1704341
- created: 2026-04-06 01:03:49
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_prod_postgres`", "DROP TABLE IF EXISTS `sfdl_prod_postgres.keplernormies_lead_fact`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_postgres.keplernormies_lead_fact`\n(\n `lead_fact_id` int , `provider_id` string , `provider` string , `status` string , `source_name` string , `company_dim_id` int , `facility_dim_id` int , `unit_dim_id` int , `tenant_dim_id` int , `date_dim_id` int , `cancelled_on_dim_id` int , `reserved_on_dim_id` int , `moved_in_on_dim_id` int , `source_dim_id` int , `migrated_on` string , `category_name` string , `received_epoch` bigint , `desired_move_in_dim_id` int , `next_action_at_dim_id` int , `next_lead_action` string , `wait_list` string , `wait_list_available` string , `quoted_rate` decimal , `deleted` string , `deleted_on_date_dim_id` int , `origination` string , `is_upgrade` string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'\n WITH SERDEPROPERTIES ( 'field.delim' = '\u0001', 'quote.delim' = '\"', 'escape.delim' = '\\\\')\nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-06/1775455334'\nTBLPROPERTIES ('skip.header.line.count' = '1')", "MSCK REPAIR TABLE sfdl_prod_postgres.keplernormies_lead_fact" ] - hive_path: s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-06/1775455334
- id: 1704341
- processed: 1
- raw_data:
{ "cancelled_on_dim_id": 10, "category_name": 15, "company_dim_id": 5, "date_dim_id": 9, "deleted": 23, "deleted_on_date_dim_id": 24, "desired_move_in_dim_id": 17, "facility_dim_id": 6, "is_upgrade": 26, "lead_fact_id": 0, "migrated_on": 14, "moved_in_on_dim_id": 12, "next_action_at_dim_id": 18, "next_lead_action": 19, "origination": 25, "provider": 2, "provider_id": 1, "quoted_rate": 22, "received_epoch": 16, "reserved_on_dim_id": 11, "source_dim_id": 13, "source_name": 4, "status": 3, "tenant_dim_id": 8, "unit_dim_id": 7, "wait_list": 20, "wait_list_available": 21 } - schema_attributes:
{ "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" } - schema_name_id: 754
- schema_scan_id: 161558789
- updated: 2026-04-06 01:04:03
-
Version 1703148
- created: 2026-04-05 00:54:28
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_prod_postgres`", "DROP TABLE IF EXISTS `sfdl_prod_postgres.keplernormies_lead_fact`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_postgres.keplernormies_lead_fact`\n(\n `lead_fact_id` int , `provider_id` string , `provider` string , `status` string , `source_name` string , `company_dim_id` int , `facility_dim_id` int , `unit_dim_id` int , `tenant_dim_id` int , `date_dim_id` int , `cancelled_on_dim_id` int , `reserved_on_dim_id` int , `moved_in_on_dim_id` int , `source_dim_id` int , `migrated_on` string , `category_name` string , `received_epoch` bigint , `desired_move_in_dim_id` int , `next_action_at_dim_id` int , `next_lead_action` string , `wait_list` string , `wait_list_available` string , `quoted_rate` decimal , `deleted` string , `deleted_on_date_dim_id` int , `origination` string , `is_upgrade` string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'\n WITH SERDEPROPERTIES ( 'field.delim' = '\u0001', 'quote.delim' = '\"', 'escape.delim' = '\\\\')\nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-05/1775368431'\nTBLPROPERTIES ('skip.header.line.count' = '1')", "MSCK REPAIR TABLE sfdl_prod_postgres.keplernormies_lead_fact" ] - hive_path: s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-05/1775368431
- id: 1703148
- processed: 1
- raw_data:
{ "cancelled_on_dim_id": 10, "category_name": 15, "company_dim_id": 5, "date_dim_id": 9, "deleted": 23, "deleted_on_date_dim_id": 24, "desired_move_in_dim_id": 17, "facility_dim_id": 6, "is_upgrade": 26, "lead_fact_id": 0, "migrated_on": 14, "moved_in_on_dim_id": 12, "next_action_at_dim_id": 18, "next_lead_action": 19, "origination": 25, "provider": 2, "provider_id": 1, "quoted_rate": 22, "received_epoch": 16, "reserved_on_dim_id": 11, "source_dim_id": 13, "source_name": 4, "status": 3, "tenant_dim_id": 8, "unit_dim_id": 7, "wait_list": 20, "wait_list_available": 21 } - schema_attributes:
{ "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" } - schema_name_id: 754
- schema_scan_id: 161511133
- updated: 2026-04-05 00:54:39
-
Version 1701960
- created: 2026-04-04 00:51:11
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_prod_postgres`", "DROP TABLE IF EXISTS `sfdl_prod_postgres.keplernormies_lead_fact`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_postgres.keplernormies_lead_fact`\n(\n `lead_fact_id` int , `provider_id` string , `provider` string , `status` string , `source_name` string , `company_dim_id` int , `facility_dim_id` int , `unit_dim_id` int , `tenant_dim_id` int , `date_dim_id` int , `cancelled_on_dim_id` int , `reserved_on_dim_id` int , `moved_in_on_dim_id` int , `source_dim_id` int , `migrated_on` string , `category_name` string , `received_epoch` bigint , `desired_move_in_dim_id` int , `next_action_at_dim_id` int , `next_lead_action` string , `wait_list` string , `wait_list_available` string , `quoted_rate` decimal , `deleted` string , `deleted_on_date_dim_id` int , `origination` string , `is_upgrade` string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'\n WITH SERDEPROPERTIES ( 'field.delim' = '\u0001', 'quote.delim' = '\"', 'escape.delim' = '\\\\')\nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-04/1775281853'\nTBLPROPERTIES ('skip.header.line.count' = '1')", "MSCK REPAIR TABLE sfdl_prod_postgres.keplernormies_lead_fact" ] - hive_path: s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-04/1775281853
- id: 1701960
- processed: 1
- raw_data:
{ "cancelled_on_dim_id": 10, "category_name": 15, "company_dim_id": 5, "date_dim_id": 9, "deleted": 23, "deleted_on_date_dim_id": 24, "desired_move_in_dim_id": 17, "facility_dim_id": 6, "is_upgrade": 26, "lead_fact_id": 0, "migrated_on": 14, "moved_in_on_dim_id": 12, "next_action_at_dim_id": 18, "next_lead_action": 19, "origination": 25, "provider": 2, "provider_id": 1, "quoted_rate": 22, "received_epoch": 16, "reserved_on_dim_id": 11, "source_dim_id": 13, "source_name": 4, "status": 3, "tenant_dim_id": 8, "unit_dim_id": 7, "wait_list": 20, "wait_list_available": 21 } - schema_attributes:
{ "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" } - schema_name_id: 754
- schema_scan_id: 161455875
- updated: 2026-04-04 00:51:25
-
Version 1700762
- created: 2026-04-03 01:02:47
- ddl:
[ "CREATE DATABASE IF NOT EXISTS `sfdl_prod_postgres`", "DROP TABLE IF EXISTS `sfdl_prod_postgres.keplernormies_lead_fact`", "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_postgres.keplernormies_lead_fact`\n(\n `lead_fact_id` int , `provider_id` string , `provider` string , `status` string , `source_name` string , `company_dim_id` int , `facility_dim_id` int , `unit_dim_id` int , `tenant_dim_id` int , `date_dim_id` int , `cancelled_on_dim_id` int , `reserved_on_dim_id` int , `moved_in_on_dim_id` int , `source_dim_id` int , `migrated_on` string , `category_name` string , `received_epoch` bigint , `desired_move_in_dim_id` int , `next_action_at_dim_id` int , `next_lead_action` string , `wait_list` string , `wait_list_available` string , `quoted_rate` decimal , `deleted` string , `deleted_on_date_dim_id` int , `origination` string , `is_upgrade` string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'\n WITH SERDEPROPERTIES ( 'field.delim' = '\u0001', 'quote.delim' = '\"', 'escape.delim' = '\\\\')\nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-03/1775195956'\nTBLPROPERTIES ('skip.header.line.count' = '1')", "MSCK REPAIR TABLE sfdl_prod_postgres.keplernormies_lead_fact" ] - hive_path: s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-03/1775195956
- id: 1700762
- processed: 1
- raw_data:
{ "cancelled_on_dim_id": 10, "category_name": 15, "company_dim_id": 5, "date_dim_id": 9, "deleted": 23, "deleted_on_date_dim_id": 24, "desired_move_in_dim_id": 17, "facility_dim_id": 6, "is_upgrade": 26, "lead_fact_id": 0, "migrated_on": 14, "moved_in_on_dim_id": 12, "next_action_at_dim_id": 18, "next_lead_action": 19, "origination": 25, "provider": 2, "provider_id": 1, "quoted_rate": 22, "received_epoch": 16, "reserved_on_dim_id": 11, "source_dim_id": 13, "source_name": 4, "status": 3, "tenant_dim_id": 8, "unit_dim_id": 7, "wait_list": 20, "wait_list_available": 21 } - schema_attributes:
{ "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" } - schema_name_id: 754
- schema_scan_id: 161398449
- updated: 2026-04-03 01:02:58
Schema Scans: 15
Last at 2026-04-17 00:56:41
-
Scan 162164096
- duration: 0:00:14.740275
- exit_message:
{ "ddl_changed": true, "partitions_applied": false, "success": true } - id: 162164096
- payload:
{ "datatype_dict": { "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" }, "file_format": "dat", "file_properties": { "data_has_header_row": true, "serde_properties": { "separatorChar": "\u0001" } }, "is_schema_datatyped": true, "s3": { "bucket": "sfdl-postgres-keplernormies-prod", "hive_path": "s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-17/1776405369", "key": "raw/lead_fact/2026-04-17/1776405369/data_0.csv.gz" }, "schema": { "name": "sfdl_prod_postgres.keplernormies_lead_fact", "type": "postgres" }, "trace_context": { "parent_id": 16816537996979755990, "service_name": "kepler-normies", "span_id": 12404681435431586643, "trace_id": 16816537996979755990 } } - running: False
- schema_name_id: 754
- start_time: 2026-04-17 00:56:41
- success: True
- trace_id: 16816537996979755990
-
Scan 162109255
- duration: 0:00:14.996245
- exit_message:
{ "ddl_changed": true, "partitions_applied": false, "success": true } - id: 162109255
- payload:
{ "datatype_dict": { "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" }, "file_format": "dat", "file_properties": { "data_has_header_row": true, "serde_properties": { "separatorChar": "\u0001" } }, "is_schema_datatyped": true, "s3": { "bucket": "sfdl-postgres-keplernormies-prod", "hive_path": "s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-16/1776319477", "key": "raw/lead_fact/2026-04-16/1776319477/data_0.csv.gz" }, "schema": { "name": "sfdl_prod_postgres.keplernormies_lead_fact", "type": "postgres" }, "trace_context": { "parent_id": 6628087500677466565, "service_name": "kepler-normies", "span_id": 10120764916321676983, "trace_id": 6628087500677466565 } } - running: False
- schema_name_id: 754
- start_time: 2026-04-16 01:04:53
- success: True
- trace_id: 6628087500677466565
-
Scan 162053415
- duration: 0:00:14.936981
- exit_message:
{ "ddl_changed": true, "partitions_applied": false, "success": true } - id: 162053415
- payload:
{ "datatype_dict": { "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" }, "file_format": "dat", "file_properties": { "data_has_header_row": true, "serde_properties": { "separatorChar": "\u0001" } }, "is_schema_datatyped": true, "s3": { "bucket": "sfdl-postgres-keplernormies-prod", "hive_path": "s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-15/1776233302", "key": "raw/lead_fact/2026-04-15/1776233302/data_0.csv.gz" }, "schema": { "name": "sfdl_prod_postgres.keplernormies_lead_fact", "type": "postgres" }, "trace_context": { "parent_id": 761177909504763331, "service_name": "kepler-normies", "span_id": 3074559279803929150, "trace_id": 761177909504763331 } } - running: False
- schema_name_id: 754
- start_time: 2026-04-15 01:08:37
- success: True
- trace_id: 761177909504763331
-
Scan 161997587
- duration: 0:00:12.212763
- exit_message:
{ "ddl_changed": true, "partitions_applied": false, "success": true } - id: 161997587
- payload:
{ "datatype_dict": { "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" }, "file_format": "dat", "file_properties": { "data_has_header_row": true, "serde_properties": { "separatorChar": "\u0001" } }, "is_schema_datatyped": true, "s3": { "bucket": "sfdl-postgres-keplernormies-prod", "hive_path": "s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-14/1776146527", "key": "raw/lead_fact/2026-04-14/1776146527/data_0.csv.gz" }, "schema": { "name": "sfdl_prod_postgres.keplernormies_lead_fact", "type": "postgres" }, "trace_context": { "parent_id": 1160921190623011227, "service_name": "kepler-normies", "span_id": 943357799200949188, "trace_id": 1160921190623011227 } } - running: False
- schema_name_id: 754
- start_time: 2026-04-14 01:02:32
- success: True
- trace_id: 1160921190623011227
-
Scan 161940056
- duration: 0:00:12.214396
- exit_message:
{ "ddl_changed": true, "partitions_applied": false, "success": true } - id: 161940056
- payload:
{ "datatype_dict": { "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" }, "file_format": "dat", "file_properties": { "data_has_header_row": true, "serde_properties": { "separatorChar": "\u0001" } }, "is_schema_datatyped": true, "s3": { "bucket": "sfdl-postgres-keplernormies-prod", "hive_path": "s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-13/1776060275", "key": "raw/lead_fact/2026-04-13/1776060275/data_0.csv.gz" }, "schema": { "name": "sfdl_prod_postgres.keplernormies_lead_fact", "type": "postgres" }, "trace_context": { "parent_id": 3060362992713201025, "service_name": "kepler-normies", "span_id": 15035617152100727511, "trace_id": 3060362992713201025 } } - running: False
- schema_name_id: 754
- start_time: 2026-04-13 01:04:57
- success: True
- trace_id: 3060362992713201025
-
Scan 161890378
- duration: 0:00:14.765005
- exit_message:
{ "ddl_changed": true, "partitions_applied": false, "success": true } - id: 161890378
- payload:
{ "datatype_dict": { "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" }, "file_format": "dat", "file_properties": { "data_has_header_row": true, "serde_properties": { "separatorChar": "\u0001" } }, "is_schema_datatyped": true, "s3": { "bucket": "sfdl-postgres-keplernormies-prod", "hive_path": "s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-12/1775973540", "key": "raw/lead_fact/2026-04-12/1775973540/data_0.csv.gz" }, "schema": { "name": "sfdl_prod_postgres.keplernormies_lead_fact", "type": "postgres" }, "trace_context": { "parent_id": 15818338806992294471, "service_name": "kepler-normies", "span_id": 6000442529874677088, "trace_id": 15818338806992294471 } } - running: False
- schema_name_id: 754
- start_time: 2026-04-12 01:02:42
- success: True
- trace_id: 15818338806992294471
-
Scan 161838639
- duration: 0:00:12.479115
- exit_message:
{ "ddl_changed": true, "partitions_applied": false, "success": true } - id: 161838639
- payload:
{ "datatype_dict": { "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" }, "file_format": "dat", "file_properties": { "data_has_header_row": true, "serde_properties": { "separatorChar": "\u0001" } }, "is_schema_datatyped": true, "s3": { "bucket": "sfdl-postgres-keplernormies-prod", "hive_path": "s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-11/1775887381", "key": "raw/lead_fact/2026-04-11/1775887381/data_0.csv.gz" }, "schema": { "name": "sfdl_prod_postgres.keplernormies_lead_fact", "type": "postgres" }, "trace_context": { "parent_id": 17346154069476377475, "service_name": "kepler-normies", "span_id": 5373178815182688643, "trace_id": 17346154069476377475 } } - running: False
- schema_name_id: 754
- start_time: 2026-04-11 01:03:18
- success: True
- trace_id: 17346154069476377475
-
Scan 161783071
- duration: 0:00:12.597047
- exit_message:
{ "ddl_changed": true, "partitions_applied": false, "success": true } - id: 161783071
- payload:
{ "datatype_dict": { "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" }, "file_format": "dat", "file_properties": { "data_has_header_row": true, "serde_properties": { "separatorChar": "\u0001" } }, "is_schema_datatyped": true, "s3": { "bucket": "sfdl-postgres-keplernormies-prod", "hive_path": "s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-10/1775800910", "key": "raw/lead_fact/2026-04-10/1775800910/data_0.csv.gz" }, "schema": { "name": "sfdl_prod_postgres.keplernormies_lead_fact", "type": "postgres" }, "trace_context": { "parent_id": 4581619657382950548, "service_name": "kepler-normies", "span_id": 16978964698869277844, "trace_id": 4581619657382950548 } } - running: False
- schema_name_id: 754
- start_time: 2026-04-10 01:02:56
- success: True
- trace_id: 4581619657382950548
-
Scan 161726789
- duration: 0:00:12.356942
- exit_message:
{ "ddl_changed": true, "partitions_applied": false, "success": true } - id: 161726789
- payload:
{ "datatype_dict": { "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" }, "file_format": "dat", "file_properties": { "data_has_header_row": true, "serde_properties": { "separatorChar": "\u0001" } }, "is_schema_datatyped": true, "s3": { "bucket": "sfdl-postgres-keplernormies-prod", "hive_path": "s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-09/1775714096", "key": "raw/lead_fact/2026-04-09/1775714096/data_0.csv.gz" }, "schema": { "name": "sfdl_prod_postgres.keplernormies_lead_fact", "type": "postgres" }, "trace_context": { "parent_id": 11357455934970196492, "service_name": "kepler-normies", "span_id": 12705782618988758351, "trace_id": 11357455934970196492 } } - running: False
- schema_name_id: 754
- start_time: 2026-04-09 00:55:14
- success: True
- trace_id: 11357455934970196492
-
Scan 161672803
- duration: 0:00:15.179248
- exit_message:
{ "ddl_changed": true, "partitions_applied": false, "success": true } - id: 161672803
- payload:
{ "datatype_dict": { "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" }, "file_format": "dat", "file_properties": { "data_has_header_row": true, "serde_properties": { "separatorChar": "\u0001" } }, "is_schema_datatyped": true, "s3": { "bucket": "sfdl-postgres-keplernormies-prod", "hive_path": "s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-08/1775628564", "key": "raw/lead_fact/2026-04-08/1775628564/data_0.csv.gz" }, "schema": { "name": "sfdl_prod_postgres.keplernormies_lead_fact", "type": "postgres" }, "trace_context": { "parent_id": 12759172453540130633, "service_name": "kepler-normies", "span_id": 1273437540003905490, "trace_id": 12759172453540130633 } } - running: False
- schema_name_id: 754
- start_time: 2026-04-08 01:09:40
- success: True
- trace_id: 12759172453540130633
-
Scan 161616693
- duration: 0:00:14.847885
- exit_message:
{ "ddl_changed": true, "partitions_applied": false, "success": true } - id: 161616693
- payload:
{ "datatype_dict": { "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" }, "file_format": "dat", "file_properties": { "data_has_header_row": true, "serde_properties": { "separatorChar": "\u0001" } }, "is_schema_datatyped": true, "s3": { "bucket": "sfdl-postgres-keplernormies-prod", "hive_path": "s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-07/1775541775", "key": "raw/lead_fact/2026-04-07/1775541775/data_0.csv.gz" }, "schema": { "name": "sfdl_prod_postgres.keplernormies_lead_fact", "type": "postgres" }, "trace_context": { "parent_id": 7367260101722299876, "service_name": "kepler-normies", "span_id": 6404277291967069202, "trace_id": 7367260101722299876 } } - running: False
- schema_name_id: 754
- start_time: 2026-04-07 01:03:13
- success: True
- trace_id: 7367260101722299876
-
Scan 161558789
- duration: 0:00:14.837780
- exit_message:
{ "ddl_changed": true, "partitions_applied": false, "success": true } - id: 161558789
- payload:
{ "datatype_dict": { "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" }, "file_format": "dat", "file_properties": { "data_has_header_row": true, "serde_properties": { "separatorChar": "\u0001" } }, "is_schema_datatyped": true, "s3": { "bucket": "sfdl-postgres-keplernormies-prod", "hive_path": "s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-06/1775455334", "key": "raw/lead_fact/2026-04-06/1775455334/data_0.csv.gz" }, "schema": { "name": "sfdl_prod_postgres.keplernormies_lead_fact", "type": "postgres" }, "trace_context": { "parent_id": 16811150906060584245, "service_name": "kepler-normies", "span_id": 14857499014171650365, "trace_id": 16811150906060584245 } } - running: False
- schema_name_id: 754
- start_time: 2026-04-06 01:03:48
- success: True
- trace_id: 16811150906060584245
-
Scan 161511133
- duration: 0:00:12.380123
- exit_message:
{ "ddl_changed": true, "partitions_applied": false, "success": true } - id: 161511133
- payload:
{ "datatype_dict": { "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" }, "file_format": "dat", "file_properties": { "data_has_header_row": true, "serde_properties": { "separatorChar": "\u0001" } }, "is_schema_datatyped": true, "s3": { "bucket": "sfdl-postgres-keplernormies-prod", "hive_path": "s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-05/1775368431", "key": "raw/lead_fact/2026-04-05/1775368431/data_0.csv.gz" }, "schema": { "name": "sfdl_prod_postgres.keplernormies_lead_fact", "type": "postgres" }, "trace_context": { "parent_id": 8159007574302652248, "service_name": "kepler-normies", "span_id": 9734874047866539457, "trace_id": 8159007574302652248 } } - running: False
- schema_name_id: 754
- start_time: 2026-04-05 00:54:27
- success: True
- trace_id: 8159007574302652248
-
Scan 161455875
- duration: 0:00:14.952470
- exit_message:
{ "ddl_changed": true, "partitions_applied": false, "success": true } - id: 161455875
- payload:
{ "datatype_dict": { "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" }, "file_format": "dat", "file_properties": { "data_has_header_row": true, "serde_properties": { "separatorChar": "\u0001" } }, "is_schema_datatyped": true, "s3": { "bucket": "sfdl-postgres-keplernormies-prod", "hive_path": "s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-04/1775281853", "key": "raw/lead_fact/2026-04-04/1775281853/data_0.csv.gz" }, "schema": { "name": "sfdl_prod_postgres.keplernormies_lead_fact", "type": "postgres" }, "trace_context": { "parent_id": 14830244256392570610, "service_name": "kepler-normies", "span_id": 5541899437981618776, "trace_id": 14830244256392570610 } } - running: False
- schema_name_id: 754
- start_time: 2026-04-04 00:51:10
- success: True
- trace_id: 14830244256392570610
-
Scan 161398449
- duration: 0:00:12.354291
- exit_message:
{ "ddl_changed": true, "partitions_applied": false, "success": true } - id: 161398449
- payload:
{ "datatype_dict": { "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" }, "file_format": "dat", "file_properties": { "data_has_header_row": true, "serde_properties": { "separatorChar": "\u0001" } }, "is_schema_datatyped": true, "s3": { "bucket": "sfdl-postgres-keplernormies-prod", "hive_path": "s3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-03/1775195956", "key": "raw/lead_fact/2026-04-03/1775195956/data_0.csv.gz" }, "schema": { "name": "sfdl_prod_postgres.keplernormies_lead_fact", "type": "postgres" }, "trace_context": { "parent_id": 3402267855050038480, "service_name": "kepler-normies", "span_id": 8184616528187253790, "trace_id": 3402267855050038480 } } - running: False
- schema_name_id: 754
- start_time: 2026-04-03 01:02:46
- success: True
- trace_id: 3402267855050038480
- attributes:
{ "cancelled_on_dim_id": "int", "category_name": "string", "company_dim_id": "int", "date_dim_id": "int", "deleted": "string", "deleted_on_date_dim_id": "int", "desired_move_in_dim_id": "int", "facility_dim_id": "int", "is_upgrade": "string", "lead_fact_id": "int", "migrated_on": "string", "moved_in_on_dim_id": "int", "next_action_at_dim_id": "int", "next_lead_action": "string", "origination": "string", "provider": "string", "provider_id": "string", "quoted_rate": "decimal", "received_epoch": "bigint", "reserved_on_dim_id": "int", "source_dim_id": "int", "source_name": "string", "status": "string", "tenant_dim_id": "int", "unit_dim_id": "int", "wait_list": "string", "wait_list_available": "string" } - created: 2026-04-17 00:56:42
- ddl:
{ "create_database": "CREATE DATABASE IF NOT EXISTS `sfdl_prod_postgres`", "create_table": "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_postgres.keplernormies_lead_fact`\n(\n `lead_fact_id` int , `provider_id` string , `provider` string , `status` string , `source_name` string , `company_dim_id` int , `facility_dim_id` int , `unit_dim_id` int , `tenant_dim_id` int , `date_dim_id` int , `cancelled_on_dim_id` int , `reserved_on_dim_id` int , `moved_in_on_dim_id` int , `source_dim_id` int , `migrated_on` string , `category_name` string , `received_epoch` bigint , `desired_move_in_dim_id` int , `next_action_at_dim_id` int , `next_lead_action` string , `wait_list` string , `wait_list_available` string , `quoted_rate` decimal , `deleted` string , `deleted_on_date_dim_id` int , `origination` string , `is_upgrade` string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'\n WITH SERDEPROPERTIES ( 'field.delim' = '\u0001', 'quote.delim' = '\"', 'escape.delim' = '\\\\')\nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-17/1776405369'\nTBLPROPERTIES ('skip.header.line.count' = '1')", "drop_table": "DROP TABLE IF EXISTS `sfdl_prod_postgres.keplernormies_lead_fact`", "repair_table": "MSCK REPAIR TABLE sfdl_prod_postgres.keplernormies_lead_fact" }
- hostname: schemamanager-5475496c57-7dpqb
- name: schema_manager
- process_start: 2026-01-09 11:27:47
- sf_env: prod
- version: 2112174301
{
"name": {
"created": "2019-10-31 03:17:54",
"disabled": false,
"format": "raw",
"id": 754,
"is_partitioned": false,
"is_schema_datatyped": true,
"name": {
"database": "sfdl_prod_postgres",
"table": "keplernormies_lead_fact"
},
"type": "postgres"
},
"partition": {
"count": 0,
"ddl": null,
"name": null,
"state": [],
"type": null
},
"schema": {
"attributes": {
"cancelled_on_dim_id": "int",
"category_name": "string",
"company_dim_id": "int",
"date_dim_id": "int",
"deleted": "string",
"deleted_on_date_dim_id": "int",
"desired_move_in_dim_id": "int",
"facility_dim_id": "int",
"is_upgrade": "string",
"lead_fact_id": "int",
"migrated_on": "string",
"moved_in_on_dim_id": "int",
"next_action_at_dim_id": "int",
"next_lead_action": "string",
"origination": "string",
"provider": "string",
"provider_id": "string",
"quoted_rate": "decimal",
"received_epoch": "bigint",
"reserved_on_dim_id": "int",
"source_dim_id": "int",
"source_name": "string",
"status": "string",
"tenant_dim_id": "int",
"unit_dim_id": "int",
"wait_list": "string",
"wait_list_available": "string"
},
"created": "2026-04-17 00:56:42",
"ddl": {
"create_database": "CREATE DATABASE IF NOT EXISTS `sfdl_prod_postgres`",
"create_table": "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_postgres.keplernormies_lead_fact`\n(\n `lead_fact_id` int , `provider_id` string , `provider` string , `status` string , `source_name` string , `company_dim_id` int , `facility_dim_id` int , `unit_dim_id` int , `tenant_dim_id` int , `date_dim_id` int , `cancelled_on_dim_id` int , `reserved_on_dim_id` int , `moved_in_on_dim_id` int , `source_dim_id` int , `migrated_on` string , `category_name` string , `received_epoch` bigint , `desired_move_in_dim_id` int , `next_action_at_dim_id` int , `next_lead_action` string , `wait_list` string , `wait_list_available` string , `quoted_rate` decimal , `deleted` string , `deleted_on_date_dim_id` int , `origination` string , `is_upgrade` string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe'\n WITH SERDEPROPERTIES ( 'field.delim' = '\u0001', 'quote.delim' = '\"', 'escape.delim' = '\\\\')\nSTORED AS INPUTFORMAT\n 'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n 's3://sfdl-postgres-keplernormies-prod/raw/lead_fact/2026-04-17/1776405369'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
"drop_table": "DROP TABLE IF EXISTS `sfdl_prod_postgres.keplernormies_lead_fact`",
"repair_table": "MSCK REPAIR TABLE sfdl_prod_postgres.keplernormies_lead_fact"
}
},
"server": {
"hostname": "schemamanager-5475496c57-7dpqb",
"name": "schema_manager",
"process_start": "2026-01-09 11:27:47",
"sf_env": "prod",
"version": "2112174301"
}
}