with lost_task_runs as (
select task_run.id
from task
inner join task_run on task.id = task_run.task
where task.policy = 'recurring' and
task.status = 'next_run_scheduled' and
task_run.status='scheduled' and
task_run.scheduled < now() - '1 days'::interval
limit 1000
)
update task_run
set status = 'lost'
from lost_task_runs
where task_run.id = lost_task_runs.id;