Skip to content

Commit

Permalink
Move Elavon secret fetch into function inside raw sync DAG (#3294)
Browse files Browse the repository at this point in the history
  • Loading branch information
SorenSpicknall authored Feb 28, 2024
1 parent 1c8caed commit 53581f6
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions airflow/dags/sync_elavon/elavon_to_gcs_raw.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@
CALITP__ELAVON_SFTP_HOSTNAME = os.environ["CALITP__ELAVON_SFTP_HOSTNAME"]
CALITP__ELAVON_SFTP_PORT = os.environ["CALITP__ELAVON_SFTP_PORT"]
CALITP__ELAVON_SFTP_USERNAME = os.environ["CALITP__ELAVON_SFTP_USERNAME"]
CALITP__ELAVON_SFTP_PASSWORD = get_secret_by_name("CALITP__ELAVON_SFTP_PASSWORD")
CALITP_BUCKET__ELAVON_RAW = os.environ["CALITP_BUCKET__ELAVON_RAW"]


Expand All @@ -29,7 +28,7 @@ def mirror_raw_files_from_elavon():
hostname=CALITP__ELAVON_SFTP_HOSTNAME,
port=CALITP__ELAVON_SFTP_PORT,
username=CALITP__ELAVON_SFTP_USERNAME,
password=CALITP__ELAVON_SFTP_PASSWORD,
password=get_secret_by_name("CALITP__ELAVON_SFTP_PASSWORD"),
)

# Create SFTP client and navigate to data directory
Expand Down

0 comments on commit 53581f6

Please sign in to comment.