Skip to content

Commit

Permalink
Update nwp-dag.py
Browse files Browse the repository at this point in the history
  • Loading branch information
devsjc committed May 5, 2024
1 parent 65be288 commit cfdf8a9
Showing 1 changed file with 15 additions and 15 deletions.
30 changes: 15 additions & 15 deletions terraform/modules/services/airflow/dags/india/nwp-dag.py
Original file line number Diff line number Diff line change
Expand Up @@ -45,21 +45,21 @@
task_concurrency=10,
)

nwp_consumer_meteomatics = EcsRunTaskOperator(
task_id=f'{region}-nwp-consumer-meteomatics-india',
task_definition='nwp-consumer-meteomatics-india',
cluster=cluster,
overrides={},
launch_type="FARGATE",
network_configuration={
"awsvpcConfiguration": {
"subnets": [subnet],
"securityGroups": [security_group],
"assignPublicIp": "ENABLED",
},
},
task_concurrency=10,
)
# nwp_consumer_meteomatics = EcsRunTaskOperator(
# task_id=f'{region}-nwp-consumer-meteomatics-india',
# task_definition='nwp-consumer-meteomatics-india',
# cluster=cluster,
# overrides={},
# launch_type="FARGATE",
# network_configuration={
# "awsvpcConfiguration": {
# "subnets": [subnet],
# "securityGroups": [security_group],
# "assignPublicIp": "ENABLED",
# },
# },
# task_concurrency=10,
# )

latest_only >> nwp_consumer_ecmwf
# latest_only >> nwp_consumer_meteomatics
Expand Down

0 comments on commit cfdf8a9

Please sign in to comment.