Adapt coscheduled_source to handle error conditions returned by level_before