Skip to content

Commit

Permalink
fix: CQDG-959 update fhir import params
Browse files Browse the repository at this point in the history
  • Loading branch information
adipaul1981 committed Jan 7, 2025
1 parent 1528d23 commit 9887920
Showing 1 changed file with 2 additions and 9 deletions.
11 changes: 2 additions & 9 deletions dags/etl_fhir_import.py
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@

def fhir_import():
csv_import = (fhir_import_config
.args(prefix(), study_clin_data_id(), study_clin_data_version(), study_code, project(), "true")
.args(prefix(), study_clin_data_id(), study_clin_data_version(), study_code, "true")
.operator(
task_id='fhir_import',
name='etl-fhir_import',
Expand All @@ -40,26 +40,19 @@ def fhir_import():
start_date=datetime(2022, 1, 1),
schedule_interval=None,
params={
'prefix': Param('prefix', type='string'),
'prefix': Param('clinical-data', type='string'),
'studyId': Param('7', type='string'),
'studyVersion': Param('13', type='string'),
'study_code': Param('cag', type='string'),
'project': Param('jmichaud', type='string'),
},
) as dag:
def prefix() -> str:
return '{{ params.prefix }}'


def study_clin_data_id() -> str:
return '{{ params.studyId }}'


def study_clin_data_version() -> str:
return '{{ params.studyVersion }}'


def project() -> str:
return '{{ params.project }}'

fhir_import()

0 comments on commit 9887920

Please sign in to comment.