"""Config for Neo4j <-> Snowflake discrepancy checks.""" CHECKS = [ { "name": "publishing_song_writer", "cypher_pattern": "(n:PublishingSongWriter)", "snowflake_table": "FACTS.PROD.PUBLISHING_SONG_WRITER", "window_property": "n.lastModifiedAt", "snowflake_window_column": "LAST_MODIFIED_AT", "key_fields": [{"neo4j": "n.id", "snowflake": "ID"}], "compare_fields": [ {"neo4j": "n.legalName", "snowflake": "LEGAL_NAME"}, {"neo4j": "n.pro", "snowflake": "PRO"}, {"neo4j": "n.ipi", "snowflake": "IPI"}, {"neo4j": "n.pubWriterID", "snowflake": "PUB_WRITER_ID"}, {"neo4j": "n.createdBy", "snowflake": "CREATED_BY"}, {"neo4j": "n.createdAt", "snowflake": "CREATED_AT"}, {"neo4j": "n.modifiedAt", "snowflake": "MODIFIED_AT"}, {"neo4j": "n.lastModifiedBy", "snowflake": "LAST_MODIFIED_BY"}, {"neo4j": "n.lastModifiedAt", "snowflake": "LAST_MODIFIED_AT"}, ], }, { "name": "publishing_agreement", "cypher_pattern": "(n:PublishingAgreement)", "snowflake_table": "FACTS.PROD.PUBLISHING_AGREEMENT", "window_property": "n.lastModifiedAt", "snowflake_window_column": "LAST_MODIFIED_AT", "key_fields": [{"neo4j": "n.id", "snowflake": "ID"}], "compare_fields": [ {"neo4j": "n.controlled", "snowflake": "CONTROLLED"}, {"neo4j": "n.excludedTerritories", "snowflake": "EXCLUDED_TERRITORIES"}, {"neo4j": "n.createdBy", "snowflake": "CREATED_BY"}, {"neo4j": "n.createdAt", "snowflake": "CREATED_AT"}, {"neo4j": "n.lastModifiedBy", "snowflake": "LAST_MODIFIED_BY"}, {"neo4j": "n.lastModifiedAt", "snowflake": "LAST_MODIFIED_AT"}, ], }, { "name": "publishing_composition", "cypher_pattern": "(n:PublishingComposition)", "snowflake_table": "FACTS.PROD.PUBLISHING_COMPOSITION", "window_property": "n.lastModifiedAt", "snowflake_window_column": "LAST_MODIFIED_AT", "key_fields": [{"neo4j": "n.id", "snowflake": "ID"}], "compare_fields": [ {"neo4j": "n.title", "snowflake": "TITLE"}, {"neo4j": "n.draft", "snowflake": "DRAFT"}, {"neo4j": "n.pubSongID", "snowflake": "PUB_SONG_ID"}, {"neo4j": "n.createdBy", "snowflake": "CREATED_BY"}, {"neo4j": "n.createdAt", "snowflake": "CREATED_AT"}, {"neo4j": "n.submittedAt", "snowflake": "SUBMITTED_AT"}, {"neo4j": "n.lastModifiedBy", "snowflake": "LAST_MODIFIED_BY"}, {"neo4j": "n.lastModifiedAt", "snowflake": "LAST_MODIFIED_AT"}, {"neo4j": "n.delivered", "snowflake": "DELIVERED"}, {"neo4j": "n.containsPublicDomain", "snowflake": "CONTAINS_PUBLIC_DOMAIN"}, {"neo4j": "n.containsSample", "snowflake": "CONTAINS_SAMPLE"}, ], }, { "name": "publishing_composition_has_agreement", "cypher_pattern": "(c:PublishingComposition)-[r:HAS_AGREEMENT]->(a:PublishingAgreement)", "snowflake_table": "FACTS.PROD.PUBLISHING_COMPOSITION_AGREEMENT", "window_property": "r.lastModifiedAt", "snowflake_window_column": "LAST_MODIFIED_AT", "key_fields": [ {"neo4j": "c.id", "snowflake": "COMPOSITION_ID"}, {"neo4j": "a.id", "snowflake": "AGREEMENT_ID"}, ], "compare_fields": [ {"neo4j": "r.hasLyricsContribution", "snowflake": "HAS_LYRICS_CONTRIBUTION"}, {"neo4j": "r.hasMusicContribution", "snowflake": "HAS_MUSIC_CONTRIBUTION"}, {"neo4j": "r.containsPublicDomain", "snowflake": "CONTAINS_PUBLIC_DOMAIN"}, {"neo4j": "r.containsSample", "snowflake": "CONTAINS_SAMPLE"}, ], }, { "name": "orchard_asset", "cypher_pattern": "(n:OrchardAsset)", "window_property": "n.lastModifiedAt", "snowflake_table": "ORCHARD_ASSET", "snowflake_window_column": "LAST_MODIFIED_AT", "key_fields": [{"neo4j": "n.id", "snowflake": "ID"}], "compare_fields": [ {"neo4j": "n.bucket", "snowflake": "BUCKET"}, {"neo4j": "n.extension", "snowflake": "EXTENSION"}, {"neo4j": "n.filename", "snowflake": "FILENAME"}, {"neo4j": "n.source", "snowflake": "SOURCE"}, {"neo4j": "n.createdBy", "snowflake": "CREATED_BY"}, {"neo4j": "n.createdAt", "snowflake": "CREATED_AT"}, {"neo4j": "n.lastModifiedBy", "snowflake": "LAST_MODIFIED_BY"}, {"neo4j": "n.lastModifiedAt", "snowflake": "LAST_MODIFIED_AT"}, ], }, { "name": "orchard_sound_recording", "cypher_pattern": "(n:OrchardSoundRecording)", "window_property": "n.lastModifiedAt", "snowflake_table": "ORCHARD_SOUND_RECORDING", "snowflake_window_column": "LAST_MODIFIED_AT", "key_fields": [{"neo4j": "n.id", "snowflake": "ID"}], "compare_fields": [ {"neo4j": "n.isrc", "snowflake": "ISRC"}, {"neo4j": "n.primaryTrackId", "snowflake": "PRIMARY_TRACK_ID"}, {"neo4j": "n.createdBy", "snowflake": "CREATED_BY"}, {"neo4j": "n.createdAt", "snowflake": "CREATED_AT"}, {"neo4j": "n.lastModifiedBy", "snowflake": "LAST_MODIFIED_BY"}, {"neo4j": "n.lastModifiedAt", "snowflake": "LAST_MODIFIED_AT"}, ], }, ]