_wrapper¶

simrun.robust_dask_delayed_execution._wrapper(db, key_first_item)¶

Wrapper to robustly compute database values.

This wrapper is used to compute delayed objects stored in a database. It ensures that the computation is only done once. It also provides locks on the files wile they are being computed, to mitigate concurrent access issues. Before, during, and after computation, the delayed objects acquire the status 'not_started', 'started', and 'finished' respectively. This wrapper is being used in RobustDaskDelayedExecution.run_db().

Parameters:¶

db : str¶

The path to the database.

key_first_item : str¶

The key of the first item in the database.