move fsync calls

openeogeotrellis/deploy/batch_job.py

@@ -293,7 +293,6 @@ def run_job(
         logger.debug("Starting process graph evaluation")
         pg_copy = deepcopy(process_graph)
         result = ProcessGraphDeserializer.evaluate(process_graph, env=env, do_dry_run=tracer)
-        os.fsync(os.open(job_dir, os.O_RDONLY))  # experiment
         logger.info("Evaluated process graph, result (type {t}): {r!r}".format(t=type(result), r=result))
 
         if isinstance(result, DelayedVector):
@@ -350,6 +349,7 @@ def run_job(
                     logger.error("samply_by_feature was set, but no geometries provided through filter_spatial. "
                                  "Make sure to provide geometries.")
             the_assets_metadata = result.write_assets(str(output_file))
+            os.fsync(os.open(job_dir, os.O_RDONLY))  # experiment
             if isinstance(result, MlModelResult):
                 ml_model_metadata = result.get_model_metadata(str(output_file))
                 logger.info("Extracted ml model metadata from %s" % output_file)
@@ -444,6 +444,7 @@ def run_job(
             ml_model_metadata=ml_model_metadata,
         )
 
+        os.fsync(os.open(job_dir, os.O_RDONLY))  # experiment
         assert len(results) == len(assets_metadata)
         for result, result_assets_metadata in zip(results, assets_metadata):
             _export_workspace(