DoesNotExist('WorkerState matching query does not exist.',)

[agutierrezrodriguez]

We have many of this errors and produced in this code:

    def update_heartbeat(self, hostname, heartbeat, update_freq):
        with transaction.atomic():
            # check if there was an update in the last n seconds?
            interval = Now() - timedelta(seconds=update_freq)
            recent_worker_updates = self.filter(
                hostname=hostname,
                last_update__gte=interval,
            )
            if recent_worker_updates.exists():
                # if yes, get the latest update and move on
                obj = recent_worker_updates.get()
            else:
                # if no, update the worker state and move on
                obj, _ = self.select_for_update_or_create(
                    hostname=hostname,
                    defaults={'last_heartbeat': heartbeat},
                )
        return obj

We have identified the bug in interval line.

Interval is generated in dynamic way (celery_monitor_workerstate.last_update >= ((CURRENT_TIMESTAMP - INTERVAL '60.000000' SECOND_MICROSECOND))) and the query results from recent_worker_updates.exists() and obj = recent_worker_updates.get() is different.

With a fixed interval value, we can avoid this bug.

[agutierrezrodriguez]

hello...

[agutierrezrodriguez]

@jezdez are you alive?

[rh0dium]

I'm still getting this was this ever pushed out as a release?

[kedare]

Nop :/

[rh0dium]