src/datamigration/dags/redshift/redshift_transfer_run_log_dag.py [117:137]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
def _get_transfer_run_summary(ti) -> None:
    """
    Calls DTS API to get transfer run summary, uses projects.transferConfigs.runs.get
    """
    transfer_config_id = ti.xcom_pull(
        key="transfer_config_id", task_ids="load_parameters"
    )
    run_id = ti.xcom_pull(key="transfer_run_id", task_ids="load_parameters")
    full_run_id = ti.xcom_pull(key="full_run_id", task_ids="load_parameters")
    unique_id = ti.xcom_pull(key="unique_id", task_ids="load_parameters")
    dts_run_summary_json = ti.xcom_pull(
        key="dts_run_summary_json", task_ids="load_parameters"
    )

    try:
        transfer_summary = (
            bq_data_transfer_client.projects()
            .locations()
            .transferConfigs()
            .runs()
            .get(name=full_run_id)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/datamigration/dags/teradata/teradata_transfer_run_log_dag.py [148:168]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
def _get_transfer_run_summary(ti) -> None:
    """
    Calls DTS API to get transfer run summary, uses projects.transferConfigs.runs.get
    """
    transfer_config_id = ti.xcom_pull(
        key="transfer_config_id", task_ids="load_parameters"
    )
    run_id = ti.xcom_pull(key="transfer_run_id", task_ids="load_parameters")
    full_run_id = ti.xcom_pull(key="full_run_id", task_ids="load_parameters")
    unique_id = ti.xcom_pull(key="unique_id", task_ids="load_parameters")
    dts_run_summary_json = ti.xcom_pull(
        key="dts_run_summary_json", task_ids="load_parameters"
    )

    try:
        transfer_summary = (
            bq_data_transfer_client.projects()
            .locations()
            .transferConfigs()
            .runs()
            .get(name=full_run_id)
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -