-record(parallel_state, {
    pending_steps :: list(binary()),
    completed_steps :: list(binary()),
    results :: gleam@dict:dict(binary(), gleam@dict:dict(binary(), binary())),
    join_step :: binary()
}).