File tree Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Expand file tree Collapse file tree 1 file changed +7
-3
lines changed Original file line number Diff line number Diff line change @@ -12,7 +12,7 @@ import pandas as pd
1212rule plot_forecast_frame :
1313 input :
1414 script = "workflow/scripts/plot_forecast_frame.mo.py" ,
15- grib_output = rules .inference_routing .output [ 0 ] ,
15+ inference_okfile = rules .execute_inference .output . okfile ,
1616 output :
1717 temp (
1818 OUT_ROOT
@@ -22,15 +22,19 @@ rule plot_forecast_frame:
2222 slurm_partition = "postproc" ,
2323 cpus_per_task = 1 ,
2424 runtime = "10m" ,
25+ params :
26+ grib_out_dir = lambda wc : (
27+ Path (OUT_ROOT ) / f"data/runs/{ wc .run_id } /{ wc .init_time } /grib"
28+ ).resolve (),
2529 shell :
2630 """
2731 export ECCODES_DEFINITION_PATH=/user-environment/share/eccodes-cosmo-resources/definitions
2832 python {input.script} \
29- --input {input.grib_output } --date {wildcards.init_time} --outfn {output[0]} \
33+ --input {params.grib_out_dir } --date {wildcards.init_time} --outfn {output[0]} \
3034 --param {wildcards.param} --leadtime {wildcards.leadtime} --region {wildcards.region} \
3135 # interactive editing (needs to set localrule: True and use only one core)
3236 # marimo edit {input.script} -- \
33- # --input {input.grib_output } --date {wildcards.init_time} --outfn {output[0]}\
37+ # --input {params.grib_out_dir } --date {wildcards.init_time} --outfn {output[0]}\
3438 # --param {wildcards.param} --leadtime {wildcards.leadtime} --region {wildcards.region}\
3539 """
3640
You can’t perform that action at this time.
0 commit comments