From 861fd0036b88f5aa385617247ca824634b63519f Mon Sep 17 00:00:00 2001
From: Emile Sonneveld <emile.sonneveld@vito.be>
Date: Tue, 22 Oct 2024 13:36:20 +0200
Subject: [PATCH] Add an fsync after evaluate, to see if it makes the output
 available for export_workspace.
 https://github.com/Open-EO/openeo-geotrellis-extensions/issues/329

---
 openeogeotrellis/deploy/batch_job.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/openeogeotrellis/deploy/batch_job.py b/openeogeotrellis/deploy/batch_job.py
index 05c7c467..b1811b0b 100644
--- a/openeogeotrellis/deploy/batch_job.py
+++ b/openeogeotrellis/deploy/batch_job.py
@@ -293,6 +293,7 @@ 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):