Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Migrate all cron jobs to dagster on Leonardo #83

Open
2 of 6 tasks
devsjc opened this issue Mar 14, 2024 · 0 comments
Open
2 of 6 tasks

Migrate all cron jobs to dagster on Leonardo #83

devsjc opened this issue Mar 14, 2024 · 0 comments
Assignees

Comments

@devsjc
Copy link
Collaborator

devsjc commented Mar 14, 2024

There remain a few cron jobs that want to be moved to dagster jobs. These probably want to be launched using the docker executor to run the consumer and pull the desired files. The required tasks are as follows:

  • ICON Global to Dagster
  • ICON EU to Dagster
  • SILAM Global to Dagster
  • MeteoFrance Global to Dagster
  • MeteoFrance Europe to Dagster
  • GPDS Global to Dagster

Many of these will also require getting working setups in the nwp consumer creating the archives and pushing them to huggingface.

For reference: Jacob's crontab: ``` #00 06 * * * source /home/jacob/miniconda3/bin/activate /home/jacob/miniconda3/envs/ocf/envs/modal && python /home/jacob/nwp/nwp/icon/app.py --run "00" --model "global" --folder "/mnt/storage_b/data/ocf/solar_pv_nowcasting/nowcasting_dataset_pipeline/NWP/DWD/ICON_Global/" --delete #00 10 * * * source /home/jacob/miniconda3/bin/activate /home/jacob/miniconda3/envs/ocf/envs/modal && python /home/jacob/nwp/nwp/icon/app.py --run "06" --model "global" --folder "/mnt/storage_b/data/ocf/solar_pv_nowcasting/nowcasting_dataset_pipeline/NWP/DWD/ICON_Global/" --delete #00 16 * * * source /home/jacob/miniconda3/bin/activate /home/jacob/miniconda3/envs/ocf/envs/modal && python /home/jacob/nwp/nwp/icon/app.py --run "12" --model "global" --folder "/mnt/storage_b/data/ocf/solar_pv_nowcasting/nowcasting_dataset_pipeline/NWP/DWD/ICON_Global/" --delete #00 22 * * * source /home/jacob/miniconda3/bin/activate /home/jacob/miniconda3/envs/ocf/envs/modal && python /home/jacob/nwp/nwp/icon/app.py --run "18" --model "global" --folder "/mnt/storage_b/data/ocf/solar_pv_nowcasting/nowcasting_dataset_pipeline/NWP/DWD/ICON_Global/" --delete #00 06 * * * source /home/jacob/miniconda3/bin/activate /home/jacob/miniconda3/envs/ocf/envs/modal && python /home/jacob/nwp/nwp/icon/app.py --run "00" --model "eu" --folder "/mnt/storage_b/data/ocf/solar_pv_nowcasting/nowcasting_dataset_pipeline/NWP/DWD/ICON_EU/" --delete #00 10 * * * source /home/jacob/miniconda3/bin/activate /home/jacob/miniconda3/envs/ocf/envs/modal && python /home/jacob/nwp/nwp/icon/app.py --run "06" --model "eu" --folder "/mnt/storage_b/data/ocf/solar_pv_nowcasting/nowcasting_dataset_pipeline/NWP/DWD/ICON_EU/" --delete #00 16 * * * source /home/jacob/miniconda3/bin/activate /home/jacob/miniconda3/envs/ocf/envs/modal && python /home/jacob/nwp/nwp/icon/app.py --run "12" --model "eu" --folder "/mnt/storage_b/data/ocf/solar_pv_nowcasting/nowcasting_dataset_pipeline/NWP/DWD/ICON_EU/" --delete #00 22 * * * source /home/jacob/miniconda3/bin/activate /home/jacob/miniconda3/envs/ocf/envs/modal && python /home/jacob/nwp/nwp/icon/app.py --run "18" --model "eu" --folder "/mnt/storage_b/data/ocf/solar_pv_nowcasting/nowcasting_dataset_pipeline/NWP/DWD/ICON_EU/" --delete #00 04 * * * source /home/jacob/miniconda3/bin/activate /home/jacob/miniconda3/envs/ocf/envs/modal && python /home/jacob/nwp/nwp/icon/app.py --run "00" --model "global" --folder "/mnt/storage_b/data/ocf/solar_pv_nowcasting/nowcasting_dataset_pipeline/NWP/DWD/ICON_Global1/" --delete #00 11 * * * source /home/jacob/miniconda3/bin/activate /home/jacob/miniconda3/envs/ocf/envs/modal && python /home/jacob/nwp/nwp/icon/app.py --run "06" --model "global" --folder "/mnt/storage_b/data/ocf/solar_pv_nowcasting/nowcasting_dataset_pipeline/NWP/DWD/ICON_Global1/" --delete #00 17 * * * source /home/jacob/miniconda3/bin/activate /home/jacob/miniconda3/envs/ocf/envs/modal && python /home/jacob/nwp/nwp/icon/app.py --run "12" --model "global" --folder "/mnt/storage_b/data/ocf/solar_pv_nowcasting/nowcasting_dataset_pipeline/NWP/DWD/ICON_Global1/" --delete #00 23 * * * source /home/jacob/miniconda3/bin/activate /home/jacob/miniconda3/envs/ocf/envs/modal && python /home/jacob/nwp/nwp/icon/app.py --run "18" --model "global" --folder "/mnt/storage_b/data/ocf/solar_pv_nowcasting/nowcasting_dataset_pipeline/NWP/DWD/ICON_Global1/" --delete #00 04 * * * source /home/jacob/miniconda3/bin/activate /home/jacob/miniconda3/envs/ocf/envs/modal && python /home/jacob/nwp/nwp/icon/app.py --run "00" --model "eu" --folder "/mnt/storage_b/data/ocf/solar_pv_nowcasting/nowcasting_dataset_pipeline/NWP/DWD/ICON_EU1/" --delete #00 11 * * * source /home/jacob/miniconda3/bin/activate /home/jacob/miniconda3/envs/ocf/envs/modal && python /home/jacob/nwp/nwp/icon/app.py --run "06" --model "eu" --folder "/mnt/storage_b/data/ocf/solar_pv_nowcasting/nowcasting_dataset_pipeline/NWP/DWD/ICON_EU1/" --delete #00 17 * * * source /home/jacob/miniconda3/bin/activate /home/jacob/miniconda3/envs/ocf/envs/modal && python /home/jacob/nwp/nwp/icon/app.py --run "12" --model "eu" --folder "/mnt/storage_b/data/ocf/solar_pv_nowcasting/nowcasting_dataset_pipeline/NWP/DWD/ICON_EU1/" --delete #00 23 * * * source /home/jacob/miniconda3/bin/activate /home/jacob/miniconda3/envs/ocf/envs/modal && python /home/jacob/nwp/nwp/icon/app.py --run "18" --model "eu" --folder "/mnt/storage_b/data/ocf/solar_pv_nowcasting/nowcasting_dataset_pipeline/NWP/DWD/ICON_EU1/" --delete 00 12 * * * aws s3 sync --no-sign-request s3://fmi-opendata-silam-surface-netcdf/ /mnt/storage_c/SILAM/ 00 12 * * * aws s3 sync --no-sign-request s3://fmi-opendata-silam-surface-zarr/ /mnt/storage_c/SILAM/ 00 23 * * * aws s3 sync --no-sign-request s3://mf-nwp-models/ /mnt/storage_c/MeteoFrance/ 00 04 * * * wget -r https://dd.weather.gc.ca/model_gem_global/15km/grib2/lat_lon/ --no-parent -m -P /mnt/storage_c/GPDS/ 00 17 * * * wget -r https://opendata.dwd.de/weather/nwp/icon/grib/ --no-parent -m -P /mnt/storage_b/DWD_Global_Backup/ 00 10 * * * wget -r https://opendata.dwd.de/weather/nwp/icon-eu/grib/00/ --no-parent -m -P /mnt/storage_c/DWD_EU_Backup/ 00 12 * * * wget -r https://opendata.dwd.de/weather/nwp/icon-eu/grib/06/ --no-parent -m -P /mnt/storage_c/DWD_EU_Backup/ 00 18 * * * wget -r https://opendata.dwd.de/weather/nwp/icon-eu/grib/12/ --no-parent -m -P /mnt/storage_c/DWD_EU_Backup/ 00 22 * * * wget -r https://opendata.dwd.de/weather/nwp/icon-eu/grib/18/ --no-parent -m -P /mnt/storage_c/DWD_EU_Backup/ 00 01 * * * wget -r https://opendata.dwd.de/weather/nwp/icon/grib/ --no-parent -m -P /mnt/elements3/DWD_Global_Backup/ 00 17 * * * wget -r https://dd.weather.gc.ca/model_gem_global/10km/ --no-parent -m -P /mnt/storage_c/GPDS/10km/ 00 06 * * * rm -rf /mnt/storage_c/MeteoFrance/arome* 00 00 * * * wget -r https://opendata.dwd.de/weather/nwp/icon-art-eu/ --no-parent -m -P /mnt/storage_b/nwp/icon/art/eu/ 00 00 * * * wget -r https://opendata.dwd.de/weather/nwp/icon-art/ --no-parent -m -P /mnt/storage_b/nwp/icon/art/global/ ```
@devsjc devsjc self-assigned this Mar 14, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant