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