Skip to content

Commit 53581f6

Browse files
Move Elavon secret fetch into function inside raw sync DAG (#3294)
1 parent 1c8caed commit 53581f6

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

airflow/dags/sync_elavon/elavon_to_gcs_raw.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@
1212
CALITP__ELAVON_SFTP_HOSTNAME = os.environ["CALITP__ELAVON_SFTP_HOSTNAME"]
1313
CALITP__ELAVON_SFTP_PORT = os.environ["CALITP__ELAVON_SFTP_PORT"]
1414
CALITP__ELAVON_SFTP_USERNAME = os.environ["CALITP__ELAVON_SFTP_USERNAME"]
15-
CALITP__ELAVON_SFTP_PASSWORD = get_secret_by_name("CALITP__ELAVON_SFTP_PASSWORD")
1615
CALITP_BUCKET__ELAVON_RAW = os.environ["CALITP_BUCKET__ELAVON_RAW"]
1716

1817

@@ -29,7 +28,7 @@ def mirror_raw_files_from_elavon():
2928
hostname=CALITP__ELAVON_SFTP_HOSTNAME,
3029
port=CALITP__ELAVON_SFTP_PORT,
3130
username=CALITP__ELAVON_SFTP_USERNAME,
32-
password=CALITP__ELAVON_SFTP_PASSWORD,
31+
password=get_secret_by_name("CALITP__ELAVON_SFTP_PASSWORD"),
3332
)
3433

3534
# Create SFTP client and navigate to data directory

0 commit comments

Comments
 (0)