def connection_string()

in src/translation/dags/validation_dag.py [0:0]


def connection_string(conn_config):
    conn_string = ""
    for key, val in conn_config:
        val = str(val)
        if key == "source_type" or key == "target_type":
            conn_type = val
            conn_name = val + "_CONN"
            continue
        conn_string = conn_string + f"--{key} '{val}' "
    if conn_type != "BigQuery":
        conn_string = (
            f"--secret-manager-type GCP --secret-manager-project-id {project_id} --connection-name {conn_name} {conn_type} "
            + conn_string
        )
    else:
        conn_string = f"--connection-name {conn_name} {conn_type} " + conn_string
    return conn_name, conn_string