Skip to content

Commit

Permalink
WIP
Browse files Browse the repository at this point in the history
  • Loading branch information
jecos committed Mar 8, 2024
1 parent 5c92b69 commit 628f0f0
Showing 1 changed file with 20 additions and 22 deletions.
42 changes: 20 additions & 22 deletions dags/lib/operators/fhavro.py
Original file line number Diff line number Diff line change
Expand Up @@ -69,14 +69,11 @@ def execute(self, **kwargs):
)
)

self.env_vars.append(
env_vars = [
k8s.V1EnvVar(
name='AWS_REGION',
value=self.aws_region,
)
)

self.env_vars.append(
),
k8s.V1EnvVar(
name='KEYCLOAK_CLIENT_SECRET',
value_from=k8s.V1EnvVarSource(
Expand All @@ -85,24 +82,25 @@ def execute(self, **kwargs):
key=self.keycloak_client_secret_key,
),
),
),
k8s.V1EnvVar(
name='KEYCLOAK_URL',
value=self.keycloak_url,
),
k8s.V1EnvVar(
name='FHIR_URL',
value=self.fhir_url,
),
k8s.V1EnvVar(
name = 'AWS_PATH_ACCESS_STYLE',
value = 'true' if self.aws_access_path_style else 'false'
),
k8s.V1EnvVar(
name='BUCKET_NAME',
value=self.bucket_name,
)
)
k8s.V1EnvVar(
name='KEYCLOAK_URL',
value=self.keycloak_url,
),
k8s.V1EnvVar(
name='FHIR_URL',
value=self.fhir_url,
),
k8s.V1EnvVar(
name = 'AWS_PATH_ACCESS_STYLE',
value = 'true' if self.aws_access_path_style else 'false'
),
k8s.V1EnvVar(
name='BUCKET_NAME',
value=self.bucket_name,
)
]
self.env_vars = [*self.env_vars, *env_vars]
self.cmds=['java',
'-cp',
'fhavro-export.jar',
Expand Down

0 comments on commit 628f0f0

Please sign in to comment.