QueueWorker plugin derivatives

Created on 13 November 2019, about 5 years ago
Updated 3 February 2024, 10 months ago

Module does not supporting QueueWorker plugin derivatives because of the way how CronJobDiscovery class processing queue worker plugin id:

$job_id = str_replace(':', '__', CronJobInterface::QUEUE_ID_PREFIX . $id);

Then in ultimate_cron module QueueWorker reverse id transformation happens only partially:

$queue_name = str_replace(CronJobInterface::QUEUE_ID_PREFIX, '', $job->id());
πŸ› Bug report
Status

Needs work

Version

2.0

Component

Code

Created by

πŸ‡ΊπŸ‡¦Ukraine dench0

Live updates comments and jobs are added and updated live.
Sign in to follow issues

Comments & Activities

Not all content is available!

It's likely this issue predates Contrib.social: some issue and comment data are missing.

  • πŸ‡¨πŸ‡¦Canada joseph.olstad

    The other issue not a duplicate

  • πŸ‡¨πŸ‡¦Canada joseph.olstad

    Hmm, neither patch seems to help in my case, I'm trying to get node_revision_delete cron to get recognized, maybe another issue involved.

  • πŸ‡¨πŸ‡­Switzerland berdir Switzerland

    Are you using the option to expose single queues as their own job?

    Either way, node_revision_delete uses a single, regular queue. Without that option, you won't see anything, but it should just work, it will always call all queues that have any data in them. Check with drush queue:list or manually in the queue table if there's any data to process.

    If you do use the option (which I don't recommend), you should see the queue job show up when you rebuild jobs, and then same.

  • πŸ‡¨πŸ‡¦Canada joseph.olstad

    node_revision_delete version 2.0.x does not have a hook_cron, it has an QueueWorker class

    /**
     * Delete revisions for a node.
     *
     * @QueueWorker(
     *   id = "node_revision_delete",
     *   title = @Translation("Node revision delete"),
     *   cron = {"time" = 300}
     * )
     */
    class NodeRevisionDelete extends QueueWorkerBase implements ContainerFactoryPluginInterface {

    with that said, node_revision_delete 1.x has a hook_cron, this works with Ultimate Cron, but not 2.0.x version of nrd

    I'm not sure if I understood your suggestion. Maybe you're not aware of the differences between node_revision_delete 1.x and 2.x

    This is the first time I've seen a QueueWorker class. I'd have to look this up to understand when it came in and what it's about.

  • πŸ‡¨πŸ‡­Switzerland berdir Switzerland

    You don't need a Job for queues, they run every time cron runs.

  • πŸ‡¨πŸ‡¦Canada joseph.olstad

    ok so is there a way to say, "queue for nrd, run only between 04:00 AM and 05:00 AM"?
    how do we set up an Ultimate Cron functionality with a queue?

  • πŸ‡¨πŸ‡­Switzerland berdir Switzerland

    > This is the first time I've seen a QueueWorker class. I'd have to look this up to understand when it came in and what it's about.

    The queue system has existed for a very long time and you *very* likely relied on them before without knowing it. media_entity in core uses queues conditionally, entity_reference_revisions uses queues for for orphan cleanup, drush queue:list probably shows a bunch of them on your project.

    A queue will only process stuff if something has explicitly added items to the queue. For node_delete_revisions, that happens when nodes are updated, then they will be checked on the next cron run. This is completely different to how 1.x worked, which had expensive queries that did run on every cron execution. Queues typically also have a fixed time limit per cron run per queue, so they run at most 30s or 60s or something like that.

    in my experience, you very rarely need to control when they run. You can do that, with the mentioned setting that will expose each queue as its own job. Then you could set them up to either not run at all and set up separate queue processing with drush queue:run or run them at specific times. But that causes risks

    The other thing you can do is alter their definition and lower their execution limit, so that they run only 10s for each cron run or so.

    This issue is a about a very specific edge case with queue workers created as derivatives, which causes invalid job names combined with that optional setting.

  • πŸ‡³πŸ‡±Netherlands Johan den Hollander

    A queue will only process stuff if something has explicitly added items to the queue. For node_delete_revisions, that happens when nodes are updated, then they will be checked on the next cron run.

    So how would this then delete revisions older then x months form a node that has not been touched recently?

  • πŸ‡¨πŸ‡­Switzerland berdir Switzerland

    I don't know and was wondering about that too, but that is an issue with node_delete_revisions, not this module. I guess at the moment the answer is "not" ;)

  • Status changed to Fixed 10 months ago
  • πŸ‡¨πŸ‡­Switzerland berdir Switzerland

    Committed this, prefer the changed separator over keeping __ of the other issue.

    This does mean that existing jobs will be duplicated, but they weren't working before, so that's fine by me.

    • Berdir β†’ committed cf28d782 on 8.x-2.x
      Revert "Issue #3094120 by dench0: QueueWorker plugin derivatives"
      
      This...
  • Status changed to Needs work 10 months ago
  • πŸ‡¨πŸ‡­Switzerland berdir Switzerland

    This breaks the updated tests which now use such a queue plugin in the edit test. This also means that we should able to test this pretty easily.

Production build 0.71.5 2024