Skip to content

Commit

Permalink
Add an fsync after evaluate, to see if it makes the output available …
Browse files Browse the repository at this point in the history
  • Loading branch information
EmileSonneveld committed Oct 22, 2024
1 parent a7c9a33 commit 861fd00
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions openeogeotrellis/deploy/batch_job.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
Expand Down

0 comments on commit 861fd00

Please sign in to comment.