Skip to content

Commit 1230a50

Browse files
committed
fix(ecsoperator): Map secrets to task definitions correctly
1 parent d81f6cb commit 1230a50

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

src/airflow_dags/plugins/operators/ecs_run_task_operator.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -93,9 +93,10 @@ def setup_operator(self) -> EcsRegisterTaskDefinitionOperator:
9393
for k, v in (self.container_env | self._default_env).items()
9494
],
9595
"secrets": [
96-
{"name": k, "valueFrom": f"arn:aws:secretsmanager:"\
97-
f"{region}:{AWS_ACCOUNT_ID}:secret:{k}",
98-
} for k in self.container_secret_env
96+
{"name": key, "valueFrom": f"arn:aws:secretsmanager:"\
97+
f"{region}:{AWS_ACCOUNT_ID}:secret:{secret}:{key}::",
98+
} for secret, keys in self.container_secret_env.items()
99+
for key in keys
99100
],
100101
"logConfiguration": {
101102
"logDriver": "awslogs",

0 commit comments

Comments
 (0)