def add_pipeline_metadata()

in probe_scraper/runner.py [0:0]

• 11 lines of code
• 4 McCabe index (conditional complexity)

def add_pipeline_metadata(pings_by_repo, repositories):
    for repo in repositories:
        metadata_defaults = repo.moz_pipeline_metadata_defaults

        current_pings = pings_by_repo.get(repo.name)
        for ping_name, ping in current_pings.items():
            ping_metadata = repo.moz_pipeline_metadata.get(ping_name, {})
            pipeline_metadata = copy.deepcopy(metadata_defaults)
            pipeline_metadata["bq_table"] = ping_name.replace("-", "_") + "_v1"

            apply_ping_specific_metadata(pipeline_metadata, ping_metadata)

            if pipeline_metadata:
                ping["moz_pipeline_metadata"] = pipeline_metadata