Merge branch 'async' of github.com:C2SM/processing-chain into async

C2SM · Jan 30, 2024 · e8fd4a7 · e8fd4a7
2 parents 8f700a1 + c9846be
commit e8fd4a7
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 3 deletions.
diff --git a/jobs/prepare_cosmo.py b/jobs/prepare_cosmo.py
@@ -62,6 +62,7 @@ def set_cfg_variables(cfg):
         cfg.meteo.inc = 1
         cfg.meteo.prefix = 'lffd'
 
+
 def main(cfg):
     """
     **COSMO Data Preparation**

diff --git a/jobs/reduce_output.py b/jobs/reduce_output.py
@@ -75,7 +75,6 @@ def main(cfg):
         cfg.output_levels = -1
     if not hasattr(cfg, 'convert_gas'):
         cfg.convert_gas = True
-
     """Get list of constant files"""
     cfiles = []
     read_cfile = False

diff --git a/run_chain.py b/run_chain.py
@@ -163,7 +163,6 @@ def run_chunk(cfg, force, resume):
         cfg.cosmo_restart_out = cfg.chain_root / 'cosmo' / 'restart'
         cfg.cosmo_restart_in = cfg.chain_root_prev / 'cosmo' / 'restart'
 
-
     if cfg.is_async:
         # Empty curent job ids
         cfg.job_ids['current'] = {}
@@ -378,7 +377,7 @@ def main():
         # Check constraint
         if cfg.constraint:
             assert cfg.constraint in ['gpu', 'mc'], ("Unknown constraint, use"
-                                                    "gpu or mc")
+                                                     "gpu or mc")
 
         # Print config before chain starts
         cfg.print_config()