Schema Info

Schema Name: sfdl_prod_csv.salesforce_account_contact_roles

created: 2022-10-10 16:21:46
disabled: False
format: raw
id: 1169
is_partitioned: False
is_schema_datatyped: True

name:

{
    "database": "sfdl_prod_csv",
    "table": "salesforce_account_contact_roles"
}

type: csv

Schema Versions: 15

Version 1718111

created: 2026-04-17 07:07:15

ddl:

[
    "CREATE DATABASE IF NOT EXISTS `sfdl_prod_csv`",
    "DROP TABLE IF EXISTS `sfdl_prod_csv.salesforce_account_contact_roles`",
    "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_csv.salesforce_account_contact_roles`\n(\n `Id`  string , `IsDeleted`  string , `CreatedDate`  string , `CreatedById`  string , `LastModifiedDate`  string , `LastModifiedById`  string , `SystemModstamp`  string , `AccountId`  string , `ContactId`  string , `Role`  string , `IsPrimary`  string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.OpenCSVSerde'\n WITH SERDEPROPERTIES ( 'separatorChar' = ',', 'quoteChar' = '\"', 'escapeChar' = '\\\\')\nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-17/1776427526'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
    "MSCK REPAIR TABLE sfdl_prod_csv.salesforce_account_contact_roles"
]

hive_path: s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-17/1776427526
id: 1718111
processed: 1

raw_data:

{
    "AccountId": 7,
    "ContactId": 8,
    "CreatedById": 3,
    "CreatedDate": 2,
    "Id": 0,
    "IsDeleted": 1,
    "IsPrimary": 10,
    "LastModifiedById": 5,
    "LastModifiedDate": 4,
    "Role": 9,
    "SystemModstamp": 6
}

schema_attributes:

{
    "AccountId": "string",
    "Amount": "string",
    "CloseDate": "string",
    "ContactId": "string",
    "CreatedById": "string",
    "CreatedDate": "string",
    "CurrencyIsoCode": "string",
    "ExpectedRevenue": "string",
    "ForecastCategory": "string",
    "Id": "string",
    "IsDeleted": "string",
    "IsPrimary": "string",
    "LastModifiedById": "string",
    "LastModifiedDate": "string",
    "OpportunityId": "string",
    "PrevAmount": "string",
    "PrevCloseDate": "string",
    "Probability": "string",
    "Role": "string",
    "StageName": "string",
    "SystemModstamp": "string"
}

schema_name_id: 1169
schema_scan_id: 162173084
updated: 2026-04-17 07:07:29

Version 1716861

created: 2026-04-16 07:06:27

ddl:

[
    "CREATE DATABASE IF NOT EXISTS `sfdl_prod_csv`",
    "DROP TABLE IF EXISTS `sfdl_prod_csv.salesforce_account_contact_roles`",
    "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_csv.salesforce_account_contact_roles`\n(\n `Id`  string , `IsDeleted`  string , `CreatedDate`  string , `CreatedById`  string , `LastModifiedDate`  string , `LastModifiedById`  string , `SystemModstamp`  string , `AccountId`  string , `ContactId`  string , `Role`  string , `IsPrimary`  string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.OpenCSVSerde'\n WITH SERDEPROPERTIES ( 'separatorChar' = ',', 'quoteChar' = '\"', 'escapeChar' = '\\\\')\nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-16/1776341113'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
    "MSCK REPAIR TABLE sfdl_prod_csv.salesforce_account_contact_roles"
]

hive_path: s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-16/1776341113
id: 1716861
processed: 1

raw_data:

{
    "AccountId": 7,
    "ContactId": 8,
    "CreatedById": 3,
    "CreatedDate": 2,
    "Id": 0,
    "IsDeleted": 1,
    "IsPrimary": 10,
    "LastModifiedById": 5,
    "LastModifiedDate": 4,
    "Role": 9,
    "SystemModstamp": 6
}

schema_attributes:

{
    "AccountId": "string",
    "Amount": "string",
    "CloseDate": "string",
    "ContactId": "string",
    "CreatedById": "string",
    "CreatedDate": "string",
    "CurrencyIsoCode": "string",
    "ExpectedRevenue": "string",
    "ForecastCategory": "string",
    "Id": "string",
    "IsDeleted": "string",
    "IsPrimary": "string",
    "LastModifiedById": "string",
    "LastModifiedDate": "string",
    "OpportunityId": "string",
    "PrevAmount": "string",
    "PrevCloseDate": "string",
    "Probability": "string",
    "Role": "string",
    "StageName": "string",
    "SystemModstamp": "string"
}

schema_name_id: 1169
schema_scan_id: 162117336
updated: 2026-04-16 07:06:38

Version 1715628

created: 2026-04-15 07:05:38

ddl:

[
    "CREATE DATABASE IF NOT EXISTS `sfdl_prod_csv`",
    "DROP TABLE IF EXISTS `sfdl_prod_csv.salesforce_account_contact_roles`",
    "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_csv.salesforce_account_contact_roles`\n(\n `Id`  string , `IsDeleted`  string , `CreatedDate`  string , `CreatedById`  string , `LastModifiedDate`  string , `LastModifiedById`  string , `SystemModstamp`  string , `AccountId`  string , `ContactId`  string , `Role`  string , `IsPrimary`  string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.OpenCSVSerde'\n WITH SERDEPROPERTIES ( 'separatorChar' = ',', 'quoteChar' = '\"', 'escapeChar' = '\\\\')\nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-15/1776254734'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
    "MSCK REPAIR TABLE sfdl_prod_csv.salesforce_account_contact_roles"
]

hive_path: s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-15/1776254734
id: 1715628
processed: 1

raw_data:

{
    "AccountId": 7,
    "ContactId": 8,
    "CreatedById": 3,
    "CreatedDate": 2,
    "Id": 0,
    "IsDeleted": 1,
    "IsPrimary": 10,
    "LastModifiedById": 5,
    "LastModifiedDate": 4,
    "Role": 9,
    "SystemModstamp": 6
}

schema_attributes:

{
    "AccountId": "string",
    "Amount": "string",
    "CloseDate": "string",
    "ContactId": "string",
    "CreatedById": "string",
    "CreatedDate": "string",
    "CurrencyIsoCode": "string",
    "ExpectedRevenue": "string",
    "ForecastCategory": "string",
    "Id": "string",
    "IsDeleted": "string",
    "IsPrimary": "string",
    "LastModifiedById": "string",
    "LastModifiedDate": "string",
    "OpportunityId": "string",
    "PrevAmount": "string",
    "PrevCloseDate": "string",
    "Probability": "string",
    "Role": "string",
    "StageName": "string",
    "SystemModstamp": "string"
}

schema_name_id: 1169
schema_scan_id: 162061759
updated: 2026-04-15 07:05:50

Version 1714466

created: 2026-04-14 07:06:35

ddl:

[
    "CREATE DATABASE IF NOT EXISTS `sfdl_prod_csv`",
    "DROP TABLE IF EXISTS `sfdl_prod_csv.salesforce_account_contact_roles`",
    "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_csv.salesforce_account_contact_roles`\n(\n `Id`  string , `IsDeleted`  string , `CreatedDate`  string , `CreatedById`  string , `LastModifiedDate`  string , `LastModifiedById`  string , `SystemModstamp`  string , `AccountId`  string , `ContactId`  string , `Role`  string , `IsPrimary`  string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.OpenCSVSerde'\n WITH SERDEPROPERTIES ( 'separatorChar' = ',', 'quoteChar' = '\"', 'escapeChar' = '\\\\')\nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-14/1776168329'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
    "MSCK REPAIR TABLE sfdl_prod_csv.salesforce_account_contact_roles"
]

hive_path: s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-14/1776168329
id: 1714466
processed: 1

raw_data:

{
    "AccountId": 7,
    "ContactId": 8,
    "CreatedById": 3,
    "CreatedDate": 2,
    "Id": 0,
    "IsDeleted": 1,
    "IsPrimary": 10,
    "LastModifiedById": 5,
    "LastModifiedDate": 4,
    "Role": 9,
    "SystemModstamp": 6
}

schema_attributes:

{
    "AccountId": "string",
    "Amount": "string",
    "CloseDate": "string",
    "ContactId": "string",
    "CreatedById": "string",
    "CreatedDate": "string",
    "CurrencyIsoCode": "string",
    "ExpectedRevenue": "string",
    "ForecastCategory": "string",
    "Id": "string",
    "IsDeleted": "string",
    "IsPrimary": "string",
    "LastModifiedById": "string",
    "LastModifiedDate": "string",
    "OpportunityId": "string",
    "PrevAmount": "string",
    "PrevCloseDate": "string",
    "Probability": "string",
    "Role": "string",
    "StageName": "string",
    "SystemModstamp": "string"
}

schema_name_id: 1169
schema_scan_id: 162006380
updated: 2026-04-14 07:06:46

Version 1713216

created: 2026-04-13 07:05:02

ddl:

[
    "CREATE DATABASE IF NOT EXISTS `sfdl_prod_csv`",
    "DROP TABLE IF EXISTS `sfdl_prod_csv.salesforce_account_contact_roles`",
    "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_csv.salesforce_account_contact_roles`\n(\n `Id`  string , `IsDeleted`  string , `CreatedDate`  string , `CreatedById`  string , `LastModifiedDate`  string , `LastModifiedById`  string , `SystemModstamp`  string , `AccountId`  string , `ContactId`  string , `Role`  string , `IsPrimary`  string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.OpenCSVSerde'\n WITH SERDEPROPERTIES ( 'separatorChar' = ',', 'quoteChar' = '\"', 'escapeChar' = '\\\\')\nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-13/1776081871'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
    "MSCK REPAIR TABLE sfdl_prod_csv.salesforce_account_contact_roles"
]

hive_path: s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-13/1776081871
id: 1713216
processed: 1

raw_data:

{
    "AccountId": 7,
    "ContactId": 8,
    "CreatedById": 3,
    "CreatedDate": 2,
    "Id": 0,
    "IsDeleted": 1,
    "IsPrimary": 10,
    "LastModifiedById": 5,
    "LastModifiedDate": 4,
    "Role": 9,
    "SystemModstamp": 6
}

schema_attributes:

{
    "AccountId": "string",
    "Amount": "string",
    "CloseDate": "string",
    "ContactId": "string",
    "CreatedById": "string",
    "CreatedDate": "string",
    "CurrencyIsoCode": "string",
    "ExpectedRevenue": "string",
    "ForecastCategory": "string",
    "Id": "string",
    "IsDeleted": "string",
    "IsPrimary": "string",
    "LastModifiedById": "string",
    "LastModifiedDate": "string",
    "OpportunityId": "string",
    "PrevAmount": "string",
    "PrevCloseDate": "string",
    "Probability": "string",
    "Role": "string",
    "StageName": "string",
    "SystemModstamp": "string"
}

schema_name_id: 1169
schema_scan_id: 161948291
updated: 2026-04-13 07:05:16

Version 1712066

created: 2026-04-12 07:08:41

ddl:

[
    "CREATE DATABASE IF NOT EXISTS `sfdl_prod_csv`",
    "DROP TABLE IF EXISTS `sfdl_prod_csv.salesforce_account_contact_roles`",
    "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_csv.salesforce_account_contact_roles`\n(\n `Id`  string , `IsDeleted`  string , `CreatedDate`  string , `CreatedById`  string , `LastModifiedDate`  string , `LastModifiedById`  string , `SystemModstamp`  string , `AccountId`  string , `ContactId`  string , `Role`  string , `IsPrimary`  string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.OpenCSVSerde'\n WITH SERDEPROPERTIES ( 'separatorChar' = ',', 'quoteChar' = '\"', 'escapeChar' = '\\\\')\nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-12/1775995701'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
    "MSCK REPAIR TABLE sfdl_prod_csv.salesforce_account_contact_roles"
]

hive_path: s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-12/1775995701
id: 1712066
processed: 1

raw_data:

{
    "AccountId": 7,
    "ContactId": 8,
    "CreatedById": 3,
    "CreatedDate": 2,
    "Id": 0,
    "IsDeleted": 1,
    "IsPrimary": 10,
    "LastModifiedById": 5,
    "LastModifiedDate": 4,
    "Role": 9,
    "SystemModstamp": 6
}

schema_attributes:

{
    "AccountId": "string",
    "Amount": "string",
    "CloseDate": "string",
    "ContactId": "string",
    "CreatedById": "string",
    "CreatedDate": "string",
    "CurrencyIsoCode": "string",
    "ExpectedRevenue": "string",
    "ForecastCategory": "string",
    "Id": "string",
    "IsDeleted": "string",
    "IsPrimary": "string",
    "LastModifiedById": "string",
    "LastModifiedDate": "string",
    "OpportunityId": "string",
    "PrevAmount": "string",
    "PrevCloseDate": "string",
    "Probability": "string",
    "Role": "string",
    "StageName": "string",
    "SystemModstamp": "string"
}

schema_name_id: 1169
schema_scan_id: 161899550
updated: 2026-04-12 07:08:52

Version 1710821

created: 2026-04-11 07:04:13

ddl:

[
    "CREATE DATABASE IF NOT EXISTS `sfdl_prod_csv`",
    "DROP TABLE IF EXISTS `sfdl_prod_csv.salesforce_account_contact_roles`",
    "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_csv.salesforce_account_contact_roles`\n(\n `Id`  string , `IsDeleted`  string , `CreatedDate`  string , `CreatedById`  string , `LastModifiedDate`  string , `LastModifiedById`  string , `SystemModstamp`  string , `AccountId`  string , `ContactId`  string , `Role`  string , `IsPrimary`  string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.OpenCSVSerde'\n WITH SERDEPROPERTIES ( 'separatorChar' = ',', 'quoteChar' = '\"', 'escapeChar' = '\\\\')\nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-11/1775909038'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
    "MSCK REPAIR TABLE sfdl_prod_csv.salesforce_account_contact_roles"
]

hive_path: s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-11/1775909038
id: 1710821
processed: 1

raw_data:

{
    "AccountId": 7,
    "ContactId": 8,
    "CreatedById": 3,
    "CreatedDate": 2,
    "Id": 0,
    "IsDeleted": 1,
    "IsPrimary": 10,
    "LastModifiedById": 5,
    "LastModifiedDate": 4,
    "Role": 9,
    "SystemModstamp": 6
}

schema_attributes:

{
    "AccountId": "string",
    "Amount": "string",
    "CloseDate": "string",
    "ContactId": "string",
    "CreatedById": "string",
    "CreatedDate": "string",
    "CurrencyIsoCode": "string",
    "ExpectedRevenue": "string",
    "ForecastCategory": "string",
    "Id": "string",
    "IsDeleted": "string",
    "IsPrimary": "string",
    "LastModifiedById": "string",
    "LastModifiedDate": "string",
    "OpportunityId": "string",
    "PrevAmount": "string",
    "PrevCloseDate": "string",
    "Probability": "string",
    "Role": "string",
    "StageName": "string",
    "SystemModstamp": "string"
}

schema_name_id: 1169
schema_scan_id: 161846830
updated: 2026-04-11 07:04:24

Version 1709644

created: 2026-04-10 07:04:49

ddl:

[
    "CREATE DATABASE IF NOT EXISTS `sfdl_prod_csv`",
    "DROP TABLE IF EXISTS `sfdl_prod_csv.salesforce_account_contact_roles`",
    "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_csv.salesforce_account_contact_roles`\n(\n `Id`  string , `IsDeleted`  string , `CreatedDate`  string , `CreatedById`  string , `LastModifiedDate`  string , `LastModifiedById`  string , `SystemModstamp`  string , `AccountId`  string , `ContactId`  string , `Role`  string , `IsPrimary`  string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.OpenCSVSerde'\n WITH SERDEPROPERTIES ( 'separatorChar' = ',', 'quoteChar' = '\"', 'escapeChar' = '\\\\')\nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-10/1775822671'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
    "MSCK REPAIR TABLE sfdl_prod_csv.salesforce_account_contact_roles"
]

hive_path: s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-10/1775822671
id: 1709644
processed: 1

raw_data:

{
    "AccountId": 7,
    "ContactId": 8,
    "CreatedById": 3,
    "CreatedDate": 2,
    "Id": 0,
    "IsDeleted": 1,
    "IsPrimary": 10,
    "LastModifiedById": 5,
    "LastModifiedDate": 4,
    "Role": 9,
    "SystemModstamp": 6
}

schema_attributes:

{
    "AccountId": "string",
    "Amount": "string",
    "CloseDate": "string",
    "ContactId": "string",
    "CreatedById": "string",
    "CreatedDate": "string",
    "CurrencyIsoCode": "string",
    "ExpectedRevenue": "string",
    "ForecastCategory": "string",
    "Id": "string",
    "IsDeleted": "string",
    "IsPrimary": "string",
    "LastModifiedById": "string",
    "LastModifiedDate": "string",
    "OpportunityId": "string",
    "PrevAmount": "string",
    "PrevCloseDate": "string",
    "Probability": "string",
    "Role": "string",
    "StageName": "string",
    "SystemModstamp": "string"
}

schema_name_id: 1169
schema_scan_id: 161792035
updated: 2026-04-10 07:05:03

Version 1708547

created: 2026-04-09 07:07:47

ddl:

[
    "CREATE DATABASE IF NOT EXISTS `sfdl_prod_csv`",
    "DROP TABLE IF EXISTS `sfdl_prod_csv.salesforce_account_contact_roles`",
    "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_csv.salesforce_account_contact_roles`\n(\n `Id`  string , `IsDeleted`  string , `CreatedDate`  string , `CreatedById`  string , `LastModifiedDate`  string , `LastModifiedById`  string , `SystemModstamp`  string , `AccountId`  string , `ContactId`  string , `Role`  string , `IsPrimary`  string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.OpenCSVSerde'\n WITH SERDEPROPERTIES ( 'separatorChar' = ',', 'quoteChar' = '\"', 'escapeChar' = '\\\\')\nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-09/1775736337'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
    "MSCK REPAIR TABLE sfdl_prod_csv.salesforce_account_contact_roles"
]

hive_path: s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-09/1775736337
id: 1708547
processed: 1

raw_data:

{
    "AccountId": 7,
    "ContactId": 8,
    "CreatedById": 3,
    "CreatedDate": 2,
    "Id": 0,
    "IsDeleted": 1,
    "IsPrimary": 10,
    "LastModifiedById": 5,
    "LastModifiedDate": 4,
    "Role": 9,
    "SystemModstamp": 6
}

schema_attributes:

{
    "AccountId": "string",
    "Amount": "string",
    "CloseDate": "string",
    "ContactId": "string",
    "CreatedById": "string",
    "CreatedDate": "string",
    "CurrencyIsoCode": "string",
    "ExpectedRevenue": "string",
    "ForecastCategory": "string",
    "Id": "string",
    "IsDeleted": "string",
    "IsPrimary": "string",
    "LastModifiedById": "string",
    "LastModifiedDate": "string",
    "OpportunityId": "string",
    "PrevAmount": "string",
    "PrevCloseDate": "string",
    "Probability": "string",
    "Role": "string",
    "StageName": "string",
    "SystemModstamp": "string"
}

schema_name_id: 1169
schema_scan_id: 161736287
updated: 2026-04-09 07:07:59

Version 1707354

created: 2026-04-08 07:07:19

ddl:

[
    "CREATE DATABASE IF NOT EXISTS `sfdl_prod_csv`",
    "DROP TABLE IF EXISTS `sfdl_prod_csv.salesforce_account_contact_roles`",
    "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_csv.salesforce_account_contact_roles`\n(\n `Id`  string , `IsDeleted`  string , `CreatedDate`  string , `CreatedById`  string , `LastModifiedDate`  string , `LastModifiedById`  string , `SystemModstamp`  string , `AccountId`  string , `ContactId`  string , `Role`  string , `IsPrimary`  string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.OpenCSVSerde'\n WITH SERDEPROPERTIES ( 'separatorChar' = ',', 'quoteChar' = '\"', 'escapeChar' = '\\\\')\nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-08/1775649923'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
    "MSCK REPAIR TABLE sfdl_prod_csv.salesforce_account_contact_roles"
]

hive_path: s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-08/1775649923
id: 1707354
processed: 1

raw_data:

{
    "AccountId": 7,
    "ContactId": 8,
    "CreatedById": 3,
    "CreatedDate": 2,
    "Id": 0,
    "IsDeleted": 1,
    "IsPrimary": 10,
    "LastModifiedById": 5,
    "LastModifiedDate": 4,
    "Role": 9,
    "SystemModstamp": 6
}

schema_attributes:

{
    "AccountId": "string",
    "Amount": "string",
    "CloseDate": "string",
    "ContactId": "string",
    "CreatedById": "string",
    "CreatedDate": "string",
    "CurrencyIsoCode": "string",
    "ExpectedRevenue": "string",
    "ForecastCategory": "string",
    "Id": "string",
    "IsDeleted": "string",
    "IsPrimary": "string",
    "LastModifiedById": "string",
    "LastModifiedDate": "string",
    "OpportunityId": "string",
    "PrevAmount": "string",
    "PrevCloseDate": "string",
    "Probability": "string",
    "Role": "string",
    "StageName": "string",
    "SystemModstamp": "string"
}

schema_name_id: 1169
schema_scan_id: 161681416
updated: 2026-04-08 07:07:31

Version 1706154

created: 2026-04-07 07:06:53

ddl:

[
    "CREATE DATABASE IF NOT EXISTS `sfdl_prod_csv`",
    "DROP TABLE IF EXISTS `sfdl_prod_csv.salesforce_account_contact_roles`",
    "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_csv.salesforce_account_contact_roles`\n(\n `Id`  string , `IsDeleted`  string , `CreatedDate`  string , `CreatedById`  string , `LastModifiedDate`  string , `LastModifiedById`  string , `SystemModstamp`  string , `AccountId`  string , `ContactId`  string , `Role`  string , `IsPrimary`  string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.OpenCSVSerde'\n WITH SERDEPROPERTIES ( 'separatorChar' = ',', 'quoteChar' = '\"', 'escapeChar' = '\\\\')\nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-07/1775563521'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
    "MSCK REPAIR TABLE sfdl_prod_csv.salesforce_account_contact_roles"
]

hive_path: s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-07/1775563521
id: 1706154
processed: 1

raw_data:

{
    "AccountId": 7,
    "ContactId": 8,
    "CreatedById": 3,
    "CreatedDate": 2,
    "Id": 0,
    "IsDeleted": 1,
    "IsPrimary": 10,
    "LastModifiedById": 5,
    "LastModifiedDate": 4,
    "Role": 9,
    "SystemModstamp": 6
}

schema_attributes:

{
    "AccountId": "string",
    "Amount": "string",
    "CloseDate": "string",
    "ContactId": "string",
    "CreatedById": "string",
    "CreatedDate": "string",
    "CurrencyIsoCode": "string",
    "ExpectedRevenue": "string",
    "ForecastCategory": "string",
    "Id": "string",
    "IsDeleted": "string",
    "IsPrimary": "string",
    "LastModifiedById": "string",
    "LastModifiedDate": "string",
    "OpportunityId": "string",
    "PrevAmount": "string",
    "PrevCloseDate": "string",
    "Probability": "string",
    "Role": "string",
    "StageName": "string",
    "SystemModstamp": "string"
}

schema_name_id: 1169
schema_scan_id: 161625195
updated: 2026-04-07 07:07:06

Version 1704911

created: 2026-04-06 07:07:34

ddl:

[
    "CREATE DATABASE IF NOT EXISTS `sfdl_prod_csv`",
    "DROP TABLE IF EXISTS `sfdl_prod_csv.salesforce_account_contact_roles`",
    "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_csv.salesforce_account_contact_roles`\n(\n `Id`  string , `IsDeleted`  string , `CreatedDate`  string , `CreatedById`  string , `LastModifiedDate`  string , `LastModifiedById`  string , `SystemModstamp`  string , `AccountId`  string , `ContactId`  string , `Role`  string , `IsPrimary`  string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.OpenCSVSerde'\n WITH SERDEPROPERTIES ( 'separatorChar' = ',', 'quoteChar' = '\"', 'escapeChar' = '\\\\')\nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-06/1775477079'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
    "MSCK REPAIR TABLE sfdl_prod_csv.salesforce_account_contact_roles"
]

hive_path: s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-06/1775477079
id: 1704911
processed: 1

raw_data:

{
    "AccountId": 7,
    "ContactId": 8,
    "CreatedById": 3,
    "CreatedDate": 2,
    "Id": 0,
    "IsDeleted": 1,
    "IsPrimary": 10,
    "LastModifiedById": 5,
    "LastModifiedDate": 4,
    "Role": 9,
    "SystemModstamp": 6
}

schema_attributes:

{
    "AccountId": "string",
    "Amount": "string",
    "CloseDate": "string",
    "ContactId": "string",
    "CreatedById": "string",
    "CreatedDate": "string",
    "CurrencyIsoCode": "string",
    "ExpectedRevenue": "string",
    "ForecastCategory": "string",
    "Id": "string",
    "IsDeleted": "string",
    "IsPrimary": "string",
    "LastModifiedById": "string",
    "LastModifiedDate": "string",
    "OpportunityId": "string",
    "PrevAmount": "string",
    "PrevCloseDate": "string",
    "Probability": "string",
    "Role": "string",
    "StageName": "string",
    "SystemModstamp": "string"
}

schema_name_id: 1169
schema_scan_id: 161567320
updated: 2026-04-06 07:07:45

Version 1703717

created: 2026-04-05 07:06:40

ddl:

[
    "CREATE DATABASE IF NOT EXISTS `sfdl_prod_csv`",
    "DROP TABLE IF EXISTS `sfdl_prod_csv.salesforce_account_contact_roles`",
    "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_csv.salesforce_account_contact_roles`\n(\n `Id`  string , `IsDeleted`  string , `CreatedDate`  string , `CreatedById`  string , `LastModifiedDate`  string , `LastModifiedById`  string , `SystemModstamp`  string , `AccountId`  string , `ContactId`  string , `Role`  string , `IsPrimary`  string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.OpenCSVSerde'\n WITH SERDEPROPERTIES ( 'separatorChar' = ',', 'quoteChar' = '\"', 'escapeChar' = '\\\\')\nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-05/1775390683'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
    "MSCK REPAIR TABLE sfdl_prod_csv.salesforce_account_contact_roles"
]

hive_path: s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-05/1775390683
id: 1703717
processed: 1

raw_data:

{
    "AccountId": 7,
    "ContactId": 8,
    "CreatedById": 3,
    "CreatedDate": 2,
    "Id": 0,
    "IsDeleted": 1,
    "IsPrimary": 10,
    "LastModifiedById": 5,
    "LastModifiedDate": 4,
    "Role": 9,
    "SystemModstamp": 6
}

schema_attributes:

{
    "AccountId": "string",
    "Amount": "string",
    "CloseDate": "string",
    "ContactId": "string",
    "CreatedById": "string",
    "CreatedDate": "string",
    "CurrencyIsoCode": "string",
    "ExpectedRevenue": "string",
    "ForecastCategory": "string",
    "Id": "string",
    "IsDeleted": "string",
    "IsPrimary": "string",
    "LastModifiedById": "string",
    "LastModifiedDate": "string",
    "OpportunityId": "string",
    "PrevAmount": "string",
    "PrevCloseDate": "string",
    "Probability": "string",
    "Role": "string",
    "StageName": "string",
    "SystemModstamp": "string"
}

schema_name_id: 1169
schema_scan_id: 161520003
updated: 2026-04-05 07:06:54

Version 1702575

created: 2026-04-04 07:09:45

ddl:

[
    "CREATE DATABASE IF NOT EXISTS `sfdl_prod_csv`",
    "DROP TABLE IF EXISTS `sfdl_prod_csv.salesforce_account_contact_roles`",
    "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_csv.salesforce_account_contact_roles`\n(\n `Id`  string , `IsDeleted`  string , `CreatedDate`  string , `CreatedById`  string , `LastModifiedDate`  string , `LastModifiedById`  string , `SystemModstamp`  string , `AccountId`  string , `ContactId`  string , `Role`  string , `IsPrimary`  string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.OpenCSVSerde'\n WITH SERDEPROPERTIES ( 'separatorChar' = ',', 'quoteChar' = '\"', 'escapeChar' = '\\\\')\nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-04/1775304416'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
    "MSCK REPAIR TABLE sfdl_prod_csv.salesforce_account_contact_roles"
]

hive_path: s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-04/1775304416
id: 1702575
processed: 1

raw_data:

{
    "AccountId": 7,
    "ContactId": 8,
    "CreatedById": 3,
    "CreatedDate": 2,
    "Id": 0,
    "IsDeleted": 1,
    "IsPrimary": 10,
    "LastModifiedById": 5,
    "LastModifiedDate": 4,
    "Role": 9,
    "SystemModstamp": 6
}

schema_attributes:

{
    "AccountId": "string",
    "Amount": "string",
    "CloseDate": "string",
    "ContactId": "string",
    "CreatedById": "string",
    "CreatedDate": "string",
    "CurrencyIsoCode": "string",
    "ExpectedRevenue": "string",
    "ForecastCategory": "string",
    "Id": "string",
    "IsDeleted": "string",
    "IsPrimary": "string",
    "LastModifiedById": "string",
    "LastModifiedDate": "string",
    "OpportunityId": "string",
    "PrevAmount": "string",
    "PrevCloseDate": "string",
    "Probability": "string",
    "Role": "string",
    "StageName": "string",
    "SystemModstamp": "string"
}

schema_name_id: 1169
schema_scan_id: 161466448
updated: 2026-04-04 07:09:59

Version 1701380

created: 2026-04-03 07:06:40

ddl:

[
    "CREATE DATABASE IF NOT EXISTS `sfdl_prod_csv`",
    "DROP TABLE IF EXISTS `sfdl_prod_csv.salesforce_account_contact_roles`",
    "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_csv.salesforce_account_contact_roles`\n(\n `Id`  string , `IsDeleted`  string , `CreatedDate`  string , `CreatedById`  string , `LastModifiedDate`  string , `LastModifiedById`  string , `SystemModstamp`  string , `AccountId`  string , `ContactId`  string , `Role`  string , `IsPrimary`  string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.OpenCSVSerde'\n WITH SERDEPROPERTIES ( 'separatorChar' = ',', 'quoteChar' = '\"', 'escapeChar' = '\\\\')\nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-03/1775217869'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
    "MSCK REPAIR TABLE sfdl_prod_csv.salesforce_account_contact_roles"
]

hive_path: s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-03/1775217869
id: 1701380
processed: 1

raw_data:

{
    "AccountId": 7,
    "ContactId": 8,
    "CreatedById": 3,
    "CreatedDate": 2,
    "Id": 0,
    "IsDeleted": 1,
    "IsPrimary": 10,
    "LastModifiedById": 5,
    "LastModifiedDate": 4,
    "Role": 9,
    "SystemModstamp": 6
}

schema_attributes:

{
    "AccountId": "string",
    "Amount": "string",
    "CloseDate": "string",
    "ContactId": "string",
    "CreatedById": "string",
    "CreatedDate": "string",
    "CurrencyIsoCode": "string",
    "ExpectedRevenue": "string",
    "ForecastCategory": "string",
    "Id": "string",
    "IsDeleted": "string",
    "IsPrimary": "string",
    "LastModifiedById": "string",
    "LastModifiedDate": "string",
    "OpportunityId": "string",
    "PrevAmount": "string",
    "PrevCloseDate": "string",
    "Probability": "string",
    "Role": "string",
    "StageName": "string",
    "SystemModstamp": "string"
}

schema_name_id: 1169
schema_scan_id: 161408590
updated: 2026-04-03 07:06:54

Schema Scans: 15

Last at 2026-04-17 07:07:15

Scan 162173084

duration: 0:00:14.660171

exit_message:

{
    "ddl_changed": true,
    "partitions_applied": false,
    "success": true
}

id: 162173084

payload:

{
    "datatype_dict": null,
    "file_format": "csv",
    "file_properties": {
        "data_has_header_row": true
    },
    "is_schema_datatyped": true,
    "s3": {
        "bucket": "sfdl-csv-salesforce-prod",
        "hive_path": "s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-17/1776427526",
        "key": "raw/account_contact_roles/2026-04-17/1776427526/account_contact_roles.csv.gz"
    },
    "schema": {
        "name": "sfdl_prod_csv.salesforce_account_contact_roles",
        "type": "csv"
    },
    "trace_context": {
        "parent_id": 14706976176222736465,
        "service_name": "drive-thru",
        "span_id": 13789048922417275837,
        "trace_id": 16974849419618391108
    }
}

running: False
schema_name_id: 1169
start_time: 2026-04-17 07:07:15
success: True
trace_id: 16974849419618391108

Scan 162117336

duration: 0:00:12.084831

exit_message:

{
    "ddl_changed": true,
    "partitions_applied": false,
    "success": true
}

id: 162117336

payload:

{
    "datatype_dict": null,
    "file_format": "csv",
    "file_properties": {
        "data_has_header_row": true
    },
    "is_schema_datatyped": true,
    "s3": {
        "bucket": "sfdl-csv-salesforce-prod",
        "hive_path": "s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-16/1776341113",
        "key": "raw/account_contact_roles/2026-04-16/1776341113/account_contact_roles.csv.gz"
    },
    "schema": {
        "name": "sfdl_prod_csv.salesforce_account_contact_roles",
        "type": "csv"
    },
    "trace_context": {
        "parent_id": 8169996335407629509,
        "service_name": "drive-thru",
        "span_id": 10178257803906192589,
        "trace_id": 13681829626012246017
    }
}

running: False
schema_name_id: 1169
start_time: 2026-04-16 07:06:26
success: True
trace_id: 13681829626012246017

Scan 162061759

duration: 0:00:12.054917

exit_message:

{
    "ddl_changed": true,
    "partitions_applied": false,
    "success": true
}

id: 162061759

payload:

{
    "datatype_dict": null,
    "file_format": "csv",
    "file_properties": {
        "data_has_header_row": true
    },
    "is_schema_datatyped": true,
    "s3": {
        "bucket": "sfdl-csv-salesforce-prod",
        "hive_path": "s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-15/1776254734",
        "key": "raw/account_contact_roles/2026-04-15/1776254734/account_contact_roles.csv.gz"
    },
    "schema": {
        "name": "sfdl_prod_csv.salesforce_account_contact_roles",
        "type": "csv"
    },
    "trace_context": {
        "parent_id": 12825224135255919781,
        "service_name": "drive-thru",
        "span_id": 7086572834573530100,
        "trace_id": 11780176184699109884
    }
}

running: False
schema_name_id: 1169
start_time: 2026-04-15 07:05:38
success: True
trace_id: 11780176184699109884

Scan 162006380

duration: 0:00:12.121560

exit_message:

{
    "ddl_changed": true,
    "partitions_applied": false,
    "success": true
}

id: 162006380

payload:

{
    "datatype_dict": null,
    "file_format": "csv",
    "file_properties": {
        "data_has_header_row": true
    },
    "is_schema_datatyped": true,
    "s3": {
        "bucket": "sfdl-csv-salesforce-prod",
        "hive_path": "s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-14/1776168329",
        "key": "raw/account_contact_roles/2026-04-14/1776168329/account_contact_roles.csv.gz"
    },
    "schema": {
        "name": "sfdl_prod_csv.salesforce_account_contact_roles",
        "type": "csv"
    },
    "trace_context": {
        "parent_id": 2645209232442788505,
        "service_name": "drive-thru",
        "span_id": 8793355753963982886,
        "trace_id": 15656502393061105722
    }
}

running: False
schema_name_id: 1169
start_time: 2026-04-14 07:06:34
success: True
trace_id: 15656502393061105722

Scan 161948291

duration: 0:00:14.517367

exit_message:

{
    "ddl_changed": true,
    "partitions_applied": false,
    "success": true
}

id: 161948291

payload:

{
    "datatype_dict": null,
    "file_format": "csv",
    "file_properties": {
        "data_has_header_row": true
    },
    "is_schema_datatyped": true,
    "s3": {
        "bucket": "sfdl-csv-salesforce-prod",
        "hive_path": "s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-13/1776081871",
        "key": "raw/account_contact_roles/2026-04-13/1776081871/account_contact_roles.csv.gz"
    },
    "schema": {
        "name": "sfdl_prod_csv.salesforce_account_contact_roles",
        "type": "csv"
    },
    "trace_context": {
        "parent_id": 9497378775799393589,
        "service_name": "drive-thru",
        "span_id": 5144899650617052807,
        "trace_id": 11378497750330120681
    }
}

running: False
schema_name_id: 1169
start_time: 2026-04-13 07:05:01
success: True
trace_id: 11378497750330120681

Scan 161899550

duration: 0:00:11.976915

exit_message:

{
    "ddl_changed": true,
    "partitions_applied": false,
    "success": true
}

id: 161899550

payload:

{
    "datatype_dict": null,
    "file_format": "csv",
    "file_properties": {
        "data_has_header_row": true
    },
    "is_schema_datatyped": true,
    "s3": {
        "bucket": "sfdl-csv-salesforce-prod",
        "hive_path": "s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-12/1775995701",
        "key": "raw/account_contact_roles/2026-04-12/1775995701/account_contact_roles.csv.gz"
    },
    "schema": {
        "name": "sfdl_prod_csv.salesforce_account_contact_roles",
        "type": "csv"
    },
    "trace_context": {
        "parent_id": 8707747546838467847,
        "service_name": "drive-thru",
        "span_id": 6333987291505192926,
        "trace_id": 1728171749146372958
    }
}

running: False
schema_name_id: 1169
start_time: 2026-04-12 07:08:40
success: True
trace_id: 1728171749146372958

Scan 161846830

duration: 0:00:12.047166

exit_message:

{
    "ddl_changed": true,
    "partitions_applied": false,
    "success": true
}

id: 161846830

payload:

{
    "datatype_dict": null,
    "file_format": "csv",
    "file_properties": {
        "data_has_header_row": true
    },
    "is_schema_datatyped": true,
    "s3": {
        "bucket": "sfdl-csv-salesforce-prod",
        "hive_path": "s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-11/1775909038",
        "key": "raw/account_contact_roles/2026-04-11/1775909038/account_contact_roles.csv.gz"
    },
    "schema": {
        "name": "sfdl_prod_csv.salesforce_account_contact_roles",
        "type": "csv"
    },
    "trace_context": {
        "parent_id": 14365894719260011261,
        "service_name": "drive-thru",
        "span_id": 4555766449664889814,
        "trace_id": 11749259554287433135
    }
}

running: False
schema_name_id: 1169
start_time: 2026-04-11 07:04:12
success: True
trace_id: 11749259554287433135

Scan 161792035

duration: 0:00:14.673576

exit_message:

{
    "ddl_changed": true,
    "partitions_applied": false,
    "success": true
}

id: 161792035

payload:

{
    "datatype_dict": null,
    "file_format": "csv",
    "file_properties": {
        "data_has_header_row": true
    },
    "is_schema_datatyped": true,
    "s3": {
        "bucket": "sfdl-csv-salesforce-prod",
        "hive_path": "s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-10/1775822671",
        "key": "raw/account_contact_roles/2026-04-10/1775822671/account_contact_roles.csv.gz"
    },
    "schema": {
        "name": "sfdl_prod_csv.salesforce_account_contact_roles",
        "type": "csv"
    },
    "trace_context": {
        "parent_id": 15342552050846648786,
        "service_name": "drive-thru",
        "span_id": 10432761672634199537,
        "trace_id": 15893185242975648893
    }
}

running: False
schema_name_id: 1169
start_time: 2026-04-10 07:04:48
success: True
trace_id: 15893185242975648893

Scan 161736287

duration: 0:00:12.137932

exit_message:

{
    "ddl_changed": true,
    "partitions_applied": false,
    "success": true
}

id: 161736287

payload:

{
    "datatype_dict": null,
    "file_format": "csv",
    "file_properties": {
        "data_has_header_row": true
    },
    "is_schema_datatyped": true,
    "s3": {
        "bucket": "sfdl-csv-salesforce-prod",
        "hive_path": "s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-09/1775736337",
        "key": "raw/account_contact_roles/2026-04-09/1775736337/account_contact_roles.csv.gz"
    },
    "schema": {
        "name": "sfdl_prod_csv.salesforce_account_contact_roles",
        "type": "csv"
    },
    "trace_context": {
        "parent_id": 721908542642014445,
        "service_name": "drive-thru",
        "span_id": 14410999187791062833,
        "trace_id": 1981178292292773612
    }
}

running: False
schema_name_id: 1169
start_time: 2026-04-09 07:07:47
success: True
trace_id: 1981178292292773612

Scan 161681416

duration: 0:00:12.257098

exit_message:

{
    "ddl_changed": true,
    "partitions_applied": false,
    "success": true
}

id: 161681416

payload:

{
    "datatype_dict": null,
    "file_format": "csv",
    "file_properties": {
        "data_has_header_row": true
    },
    "is_schema_datatyped": true,
    "s3": {
        "bucket": "sfdl-csv-salesforce-prod",
        "hive_path": "s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-08/1775649923",
        "key": "raw/account_contact_roles/2026-04-08/1775649923/account_contact_roles.csv.gz"
    },
    "schema": {
        "name": "sfdl_prod_csv.salesforce_account_contact_roles",
        "type": "csv"
    },
    "trace_context": {
        "parent_id": 13591296342336169580,
        "service_name": "drive-thru",
        "span_id": 9095041250150434873,
        "trace_id": 8339554182879744566
    }
}

running: False
schema_name_id: 1169
start_time: 2026-04-08 07:07:19
success: True
trace_id: 8339554182879744566

Scan 161625195

duration: 0:00:14.711594

exit_message:

{
    "ddl_changed": true,
    "partitions_applied": false,
    "success": true
}

id: 161625195

payload:

{
    "datatype_dict": null,
    "file_format": "csv",
    "file_properties": {
        "data_has_header_row": true
    },
    "is_schema_datatyped": true,
    "s3": {
        "bucket": "sfdl-csv-salesforce-prod",
        "hive_path": "s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-07/1775563521",
        "key": "raw/account_contact_roles/2026-04-07/1775563521/account_contact_roles.csv.gz"
    },
    "schema": {
        "name": "sfdl_prod_csv.salesforce_account_contact_roles",
        "type": "csv"
    },
    "trace_context": {
        "parent_id": 13559575766410137542,
        "service_name": "drive-thru",
        "span_id": 17349616984449603725,
        "trace_id": 5915247012679181302
    }
}

running: False
schema_name_id: 1169
start_time: 2026-04-07 07:06:52
success: True
trace_id: 5915247012679181302

Scan 161567320

duration: 0:00:12.209647

exit_message:

{
    "ddl_changed": true,
    "partitions_applied": false,
    "success": true
}

id: 161567320

payload:

{
    "datatype_dict": null,
    "file_format": "csv",
    "file_properties": {
        "data_has_header_row": true
    },
    "is_schema_datatyped": true,
    "s3": {
        "bucket": "sfdl-csv-salesforce-prod",
        "hive_path": "s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-06/1775477079",
        "key": "raw/account_contact_roles/2026-04-06/1775477079/account_contact_roles.csv.gz"
    },
    "schema": {
        "name": "sfdl_prod_csv.salesforce_account_contact_roles",
        "type": "csv"
    },
    "trace_context": {
        "parent_id": 17981170307551603682,
        "service_name": "drive-thru",
        "span_id": 15928696442772724659,
        "trace_id": 11848266952271110660
    }
}

running: False
schema_name_id: 1169
start_time: 2026-04-06 07:07:33
success: True
trace_id: 11848266952271110660

Scan 161520003

duration: 0:00:14.553421

exit_message:

{
    "ddl_changed": true,
    "partitions_applied": false,
    "success": true
}

id: 161520003

payload:

{
    "datatype_dict": null,
    "file_format": "csv",
    "file_properties": {
        "data_has_header_row": true
    },
    "is_schema_datatyped": true,
    "s3": {
        "bucket": "sfdl-csv-salesforce-prod",
        "hive_path": "s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-05/1775390683",
        "key": "raw/account_contact_roles/2026-04-05/1775390683/account_contact_roles.csv.gz"
    },
    "schema": {
        "name": "sfdl_prod_csv.salesforce_account_contact_roles",
        "type": "csv"
    },
    "trace_context": {
        "parent_id": 10610238229750559387,
        "service_name": "drive-thru",
        "span_id": 14943415365372394564,
        "trace_id": 11928241557527133945
    }
}

running: False
schema_name_id: 1169
start_time: 2026-04-05 07:06:39
success: True
trace_id: 11928241557527133945

Scan 161466448

duration: 0:00:14.580084

exit_message:

{
    "ddl_changed": true,
    "partitions_applied": false,
    "success": true
}

id: 161466448

payload:

{
    "datatype_dict": null,
    "file_format": "csv",
    "file_properties": {
        "data_has_header_row": true
    },
    "is_schema_datatyped": true,
    "s3": {
        "bucket": "sfdl-csv-salesforce-prod",
        "hive_path": "s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-04/1775304416",
        "key": "raw/account_contact_roles/2026-04-04/1775304416/account_contact_roles.csv.gz"
    },
    "schema": {
        "name": "sfdl_prod_csv.salesforce_account_contact_roles",
        "type": "csv"
    },
    "trace_context": {
        "parent_id": 3421447229275858775,
        "service_name": "drive-thru",
        "span_id": 7198647503786278099,
        "trace_id": 9089676245782238240
    }
}

running: False
schema_name_id: 1169
start_time: 2026-04-04 07:09:44
success: True
trace_id: 9089676245782238240

Scan 161408590

duration: 0:00:14.590934

exit_message:

{
    "ddl_changed": true,
    "partitions_applied": false,
    "success": true
}

id: 161408590

payload:

{
    "datatype_dict": null,
    "file_format": "csv",
    "file_properties": {
        "data_has_header_row": true
    },
    "is_schema_datatyped": true,
    "s3": {
        "bucket": "sfdl-csv-salesforce-prod",
        "hive_path": "s3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-03/1775217869",
        "key": "raw/account_contact_roles/2026-04-03/1775217869/account_contact_roles.csv.gz"
    },
    "schema": {
        "name": "sfdl_prod_csv.salesforce_account_contact_roles",
        "type": "csv"
    },
    "trace_context": {
        "parent_id": 11051575639352398116,
        "service_name": "drive-thru",
        "span_id": 11026519331366418436,
        "trace_id": 13657030072847087926
    }
}

running: False
schema_name_id: 1169
start_time: 2026-04-03 07:06:39
success: True
trace_id: 13657030072847087926

Partitions:

count: 0
ddl: None
name: None
state:
```
[]
```
type: None

Schema:

attributes:

{
    "AccountId": "string",
    "Amount": "string",
    "CloseDate": "string",
    "ContactId": "string",
    "CreatedById": "string",
    "CreatedDate": "string",
    "CurrencyIsoCode": "string",
    "ExpectedRevenue": "string",
    "ForecastCategory": "string",
    "Id": "string",
    "IsDeleted": "string",
    "IsPrimary": "string",
    "LastModifiedById": "string",
    "LastModifiedDate": "string",
    "OpportunityId": "string",
    "PrevAmount": "string",
    "PrevCloseDate": "string",
    "Probability": "string",
    "Role": "string",
    "StageName": "string",
    "SystemModstamp": "string"
}

created: 2026-04-17 07:07:15

ddl:

{
    "create_database": "CREATE DATABASE IF NOT EXISTS `sfdl_prod_csv`",
    "create_table": "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_csv.salesforce_account_contact_roles`\n(\n `Id`  string , `IsDeleted`  string , `CreatedDate`  string , `CreatedById`  string , `LastModifiedDate`  string , `LastModifiedById`  string , `SystemModstamp`  string , `AccountId`  string , `ContactId`  string , `Role`  string , `IsPrimary`  string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.OpenCSVSerde'\n WITH SERDEPROPERTIES ( 'separatorChar' = ',', 'quoteChar' = '\"', 'escapeChar' = '\\\\')\nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-17/1776427526'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
    "drop_table": "DROP TABLE IF EXISTS `sfdl_prod_csv.salesforce_account_contact_roles`",
    "repair_table": "MSCK REPAIR TABLE sfdl_prod_csv.salesforce_account_contact_roles"
}

Server:

hostname: schemamanager-5475496c57-7dpqb
name: schema_manager
process_start: 2026-01-09 11:27:47
sf_env: prod
version: 2112174301

Raw:

{
    "name": {
        "created": "2022-10-10 16:21:46",
        "disabled": false,
        "format": "raw",
        "id": 1169,
        "is_partitioned": false,
        "is_schema_datatyped": true,
        "name": {
            "database": "sfdl_prod_csv",
            "table": "salesforce_account_contact_roles"
        },
        "type": "csv"
    },
    "partition": {
        "count": 0,
        "ddl": null,
        "name": null,
        "state": [],
        "type": null
    },
    "schema": {
        "attributes": {
            "AccountId": "string",
            "Amount": "string",
            "CloseDate": "string",
            "ContactId": "string",
            "CreatedById": "string",
            "CreatedDate": "string",
            "CurrencyIsoCode": "string",
            "ExpectedRevenue": "string",
            "ForecastCategory": "string",
            "Id": "string",
            "IsDeleted": "string",
            "IsPrimary": "string",
            "LastModifiedById": "string",
            "LastModifiedDate": "string",
            "OpportunityId": "string",
            "PrevAmount": "string",
            "PrevCloseDate": "string",
            "Probability": "string",
            "Role": "string",
            "StageName": "string",
            "SystemModstamp": "string"
        },
        "created": "2026-04-17 07:07:15",
        "ddl": {
            "create_database": "CREATE DATABASE IF NOT EXISTS `sfdl_prod_csv`",
            "create_table": "CREATE EXTERNAL TABLE IF NOT EXISTS\n`sfdl_prod_csv.salesforce_account_contact_roles`\n(\n `Id`  string , `IsDeleted`  string , `CreatedDate`  string , `CreatedById`  string , `LastModifiedDate`  string , `LastModifiedById`  string , `SystemModstamp`  string , `AccountId`  string , `ContactId`  string , `Role`  string , `IsPrimary`  string \n)\nROW FORMAT SERDE\n'org.apache.hadoop.hive.serde2.OpenCSVSerde'\n WITH SERDEPROPERTIES ( 'separatorChar' = ',', 'quoteChar' = '\"', 'escapeChar' = '\\\\')\nSTORED AS INPUTFORMAT\n  'org.apache.hadoop.mapred.TextInputFormat'\nOUTPUTFORMAT\n  'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'\nLOCATION\n  's3://sfdl-csv-salesforce-prod/raw/account_contact_roles/2026-04-17/1776427526'\nTBLPROPERTIES ('skip.header.line.count' = '1')",
            "drop_table": "DROP TABLE IF EXISTS `sfdl_prod_csv.salesforce_account_contact_roles`",
            "repair_table": "MSCK REPAIR TABLE sfdl_prod_csv.salesforce_account_contact_roles"
        }
    },
    "server": {
        "hostname": "schemamanager-5475496c57-7dpqb",
        "name": "schema_manager",
        "process_start": "2026-01-09 11:27:47",
        "sf_env": "prod",
        "version": "2112174301"
    }
}