Skip to content

repair only affects one job #13

@robshep

Description

@robshep

The use of find_and_modify means only one Job is recovered from stale lock.

The same query + update expressions work with the PyMongo function update_many which updates all documents that match.

it = q.collection.update_many({"locked_by": {"$ne": None}, "locked_at": { "$lt": datetime.now() - timedelta(0.125)}},{"$set": {"locked_by": None, "locked_at": None},"$inc": {"attempts": 1}})

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions