Skip to content

Commit 551ed5f

Browse files
use .zattrs when looking nwp has been updated (#744)
1 parent 1c38c56 commit 551ed5f

File tree

1 file changed

+2
-2
lines changed
  • terraform/modules/services/airflow/dags/uk

1 file changed

+2
-2
lines changed

terraform/modules/services/airflow/dags/uk/nwp-dag.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -75,14 +75,14 @@
7575
task_id="determine_latest_zarr_ecmwf",
7676
)(bucket=f'nowcasting-nwp-{env}', prefix='ecmwf/data')
7777

78-
file = f's3://nowcasting-nwp-{env}/data-metoffice/latest.zarr'
78+
file = f's3://nowcasting-nwp-{env}/data-metoffice/latest.zarr/.zattrs'
7979
command = f'curl -X GET "{url}/v0/solar/GB/update_last_data?component=nwp&file={file}"'
8080
nwp_update_ukv = BashOperator(
8181
task_id="nwp-update-ukv",
8282
bash_command=command,
8383
)
8484

85-
file = f's3://nowcasting-nwp-{env}/ecmwf/data/latest.zarr'
85+
file = f's3://nowcasting-nwp-{env}/ecmwf/data/latest.zarr/.zattrs'
8686
command = f'curl -X GET "{url}/v0/solar/GB/update_last_data?component=nwp&file={file}"'
8787
nwp_update_ecmwf = BashOperator(
8888
task_id="nwp-update-ecmwf",

0 commit comments

Comments
 (0)