Skip to content

Commit

Permalink
Merge branch 'main' into fmd-808-nginx-rate-limiting-limit-whitelist
Browse files Browse the repository at this point in the history
  • Loading branch information
mitchdawson1982 authored Nov 12, 2024
2 parents b9987f9 + 252d9c8 commit f3836ca
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 1 deletion.
7 changes: 6 additions & 1 deletion ingestion/cadet.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ source:
# These tables cause a `java.lang.NullPointerException` and are staging tables anyway
- ".*avature_stg\\.stg_people_fields_pivoted_wide.*"
- ".*avature_stg\\.stg_job_fields_pivoted_wide.*"


# This table has a huge number of columns, which breaks things.
- "source.mojap_derived_tables.data_eng_uploader_prod_calc_release_dates.survey_data"
Expand Down Expand Up @@ -63,3 +63,8 @@ transformers:
- type: "ingestion.transformers.assign_cadet_databases.AssignCadetDatabases"
config:
manifest_s3_uri: "s3://mojap-derived-tables/prod/run_artefacts/latest/target/manifest.json"
- type: "simple_add_dataset_properties"
config:
properties:
Audience: Internal
Provider: Analytical Platform
6 changes: 6 additions & 0 deletions ingestion/create_cadet_databases_source/source.py
Original file line number Diff line number Diff line change
Expand Up @@ -32,6 +32,11 @@

logging.basicConfig(level=logging.DEBUG)

properties_to_add = {
"Audience": "Internal",
"Provider": "Analytical Platform"
}


@config_class(CreateCadetDatabasesConfig)
class CreateCadetDatabases(Source):
Expand Down Expand Up @@ -117,6 +122,7 @@ def create_database_mcps(
backcompat_env_as_instance=True,
)
db_meta_dict = dict(database_metadata)
db_meta_dict.update(properties_to_add)
domain_name = format_domain_name(db_meta_dict["domain"])
domain_urn = mce_builder.make_domain_urn(domain=domain_name)
display_tag = display_tags.get(database_name, ["dc_cadet"])
Expand Down

0 comments on commit f3836ca

Please sign in to comment.