Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Debug mode for queue:worker:start and queue:task:start console commands #5

Open
wants to merge 6 commits into
base: master
Choose a base branch
from

Conversation

EvgenyNekhamkin
Copy link

@EvgenyNekhamkin EvgenyNekhamkin commented Oct 21, 2024

PR Description

There are already verbose modes for those commands which are currently functioning as a kind of dashboard. Our goal is to create a new output which is more suitable for debugging of a concrete queue which is currently busy so that one can see more details like a message payload for example.

The new output is provided by adding the verbosity level debug -vvv to those commands for example:
console queue:worker:start -s -vvv
console queue:task:start publish -vvv

grafik

The output with verbosity level normal -v remains untouched.

Checklist

  • I agree with the Code Contribution License Agreement in CONTRIBUTING.md

@RodinVasily
Copy link

Also, both verbose modes can show errors, which happen during the queue processing:

-->  DEVELOPMENT MODE
Store: DE | Code bucket: DE | Environment: docker.dev
Start processing messages
Messages: 4

Message #0
{
    "listenerClassName": "Spryker\\Zed\\CmsStorage\\Communication\\Plugin\\Event\\Listener\\CmsPageStoragePublishListener",
    "transferClassName": "Generated\\Shared\\Transfer\\EventEntityTransfer",
    "transferData": {
        "id": "1431",
        "additional_values": [],
        "modified_columns": [],
        "event": null,
        "name": null,
        "foreign_keys": [],
        "original_values": []
    },
    "eventName": "Cms.version.publish"
}

Message #1
{
    "listenerClassName": "Spryker\\Zed\\CmsPageSearch\\Communication\\Plugin\\Event\\Listener\\CmsPageSearchListener",
    "transferClassName": "Generated\\Shared\\Transfer\\EventEntityTransfer",
    "transferData": {
        "id": "1431",
        "additional_values": [],
        "modified_columns": [],
        "event": null,
        "name": null,
        "foreign_keys": [],
        "original_values": []
    },
    "eventName": "Cms.version.publish"
}

Message #2
{
    "listenerClassName": "Pyz\\Zed\\MeuCmsPageAliasStorage\\Communication\\Plugin\\Event\\Listener\\CmsPageMappingResourceStorageListener",
    "transferClassName": "Generated\\Shared\\Transfer\\EventEntityTransfer",
    "transferData": {
        "id": "1431",
        "additional_values": [],
        "modified_columns": [],
        "event": null,
        "name": null,
        "foreign_keys": [],
        "original_values": []
    },
    "eventName": "Cms.version.publish"
}

Message #3
{
    "listenerClassName": "Spryker\\Zed\\CmsPageSearch\\Communication\\Plugin\\Event\\Listener\\CmsPageSearchListener",
    "transferClassName": "Generated\\Shared\\Transfer\\EventEntityTransfer",
    "transferData": {
        "id": "1431",
        "additional_values": [],
        "modified_columns": [],
        "event": null,
        "name": null,
        "foreign_keys": [],
        "original_values": []
    },
    "eventName": "Cms.version.publish"
}

Finish processing messages
Processed messages: 4
Processing time: 0.25026988983154s

Error in message #1
Error message: Failed to handle "Cms.version.publish" for listener "Spryker\Zed\CmsPageSearch\Communication\Plugin\Event\Listener\CmsPageSearchListener". Exception: "Something happened", "#0 /data/vendor/spryker/event/src/Spryker/Zed/Event/Business/Queue/Consumer/EventQueueConsumer.php(175): Spryker\Zed\CmsPageSearch\Communication\Plugin\Event\Listener\CmsPageSearchListener->handleBulk(Array, 'Cms.version.pub...')
#1 /data/vendor/spryker/event/src/Spryker/Zed/Event/Business/Queue/Consumer/EventQueueConsumer.php(154): Spryker\Zed\Event\Business\Queue\Consumer\EventQueueConsumer->handleBulkItemsIndividually(Array, 'Cms.version.pub...', Object(Spryker\Zed\CmsPageSearch\Communication\Plugin\Event\Listener\CmsPageSearchListener), 'Spryker\\Zed\\Cms...')
#2 /data/vendor/spryker/event/src/Spryker/Zed/Event/Business/Queue/Consumer/EventQueueConsumer.php(125): Spryker\Zed\Event\Business\Queue\Consumer\EventQueueConsumer->handleBulk(Array, 'Spryker\\Zed\\Cms...')
#3 /data/vendor/spryker/event/src/Spryker/Zed/Event/Business/EventFacade.php(83): Spryker\Zed\Event\Business\Queue\Consumer\EventQueueConsumer->processMessages(Array)
#4 /data/vendor/spryker/event/src/Spryker/Zed/Event/Communication/Plugin/Queue/EventQueueMessageProcessorPlugin.php(31): Spryker\Zed\Event\Business\EventFacade->processEnqueuedMessages(Array)
#5 /data/src/Pyz/Zed/Queue/Business/Task/TaskManager.php(71): Spryker\Zed\Event\Communication\Plugin\Queue\EventQueueMessageProcessorPlugin->processMessages(Array)
#6 /data/src/Pyz/Zed/Queue/Business/QueueFacade.php(33): Pyz\Zed\Queue\Business\Task\TaskManager->run('publish.cms', Array)
#7 /data/src/Pyz/Zed/Queue/Communication/Console/QueueTaskConsole.php(71): Pyz\Zed\Queue\Business\QueueFacade->startTaskWithOutput('publish.cms', Object(Symfony\Component\Console\Output\ConsoleOutput), Array)
#8 /data/vendor/symfony/console/Command/Command.php(298): Pyz\Zed\Queue\Communication\Console\QueueTaskConsole->execute(Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
#9 /data/vendor/symfony/console/Application.php(1058): Symfony\Component\Console\Command\Command->run(Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
#10 /data/vendor/symfony/console/Application.php(301): Symfony\Component\Console\Application->doRunCommand(Object(Pyz\Zed\Queue\Communication\Console\QueueTaskConsole), Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
#11 /data/vendor/spryker/console/src/Spryker/Zed/Console/Communication/Bootstrap/ConsoleBootstrap.php(115): Symfony\Component\Console\Application->doRun(Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
#12 /data/vendor/symfony/console/Application.php(171): Spryker\Zed\Console\Communication\Bootstrap\ConsoleBootstrap->doRun(Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
#13 /data/vendor/spryker/console/bin/console(27): Symfony\Component\Console\Application->run()
#14 /data/vendor/bin/console(119): include('/data/vendor/sp...')
#15 {main}".

Error in message #3
Error message: Failed to handle "Cms.version.publish" for listener "Spryker\Zed\CmsPageSearch\Communication\Plugin\Event\Listener\CmsPageSearchListener". Exception: "Something happened", "#0 /data/vendor/spryker/event/src/Spryker/Zed/Event/Business/Queue/Consumer/EventQueueConsumer.php(175): Spryker\Zed\CmsPageSearch\Communication\Plugin\Event\Listener\CmsPageSearchListener->handleBulk(Array, 'Cms.version.pub...')
#1 /data/vendor/spryker/event/src/Spryker/Zed/Event/Business/Queue/Consumer/EventQueueConsumer.php(154): Spryker\Zed\Event\Business\Queue\Consumer\EventQueueConsumer->handleBulkItemsIndividually(Array, 'Cms.version.pub...', Object(Spryker\Zed\CmsPageSearch\Communication\Plugin\Event\Listener\CmsPageSearchListener), 'Spryker\\Zed\\Cms...')
#2 /data/vendor/spryker/event/src/Spryker/Zed/Event/Business/Queue/Consumer/EventQueueConsumer.php(125): Spryker\Zed\Event\Business\Queue\Consumer\EventQueueConsumer->handleBulk(Array, 'Spryker\\Zed\\Cms...')
#3 /data/vendor/spryker/event/src/Spryker/Zed/Event/Business/EventFacade.php(83): Spryker\Zed\Event\Business\Queue\Consumer\EventQueueConsumer->processMessages(Array)
#4 /data/vendor/spryker/event/src/Spryker/Zed/Event/Communication/Plugin/Queue/EventQueueMessageProcessorPlugin.php(31): Spryker\Zed\Event\Business\EventFacade->processEnqueuedMessages(Array)
#5 /data/src/Pyz/Zed/Queue/Business/Task/TaskManager.php(71): Spryker\Zed\Event\Communication\Plugin\Queue\EventQueueMessageProcessorPlugin->processMessages(Array)
#6 /data/src/Pyz/Zed/Queue/Business/QueueFacade.php(33): Pyz\Zed\Queue\Business\Task\TaskManager->run('publish.cms', Array)
#7 /data/src/Pyz/Zed/Queue/Communication/Console/QueueTaskConsole.php(71): Pyz\Zed\Queue\Business\QueueFacade->startTaskWithOutput('publish.cms', Object(Symfony\Component\Console\Output\ConsoleOutput), Array)
#8 /data/vendor/symfony/console/Command/Command.php(298): Pyz\Zed\Queue\Communication\Console\QueueTaskConsole->execute(Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
#9 /data/vendor/symfony/console/Application.php(1058): Symfony\Component\Console\Command\Command->run(Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
#10 /data/vendor/symfony/console/Application.php(301): Symfony\Component\Console\Application->doRunCommand(Object(Pyz\Zed\Queue\Communication\Console\QueueTaskConsole), Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
#11 /data/vendor/spryker/console/src/Spryker/Zed/Console/Communication/Bootstrap/ConsoleBootstrap.php(115): Symfony\Component\Console\Application->doRun(Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
#12 /data/vendor/symfony/console/Application.php(171): Spryker\Zed\Console\Communication\Bootstrap\ConsoleBootstrap->doRun(Object(Symfony\Component\Console\Input\ArgvInput), Object(Symfony\Component\Console\Output\ConsoleOutput))
#13 /data/vendor/spryker/console/bin/console(27): Symfony\Component\Console\Application->run()
#14 /data/vendor/bin/console(119): include('/data/vendor/sp...')
#15 {main}".

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Development

Successfully merging this pull request may close these issues.

2 participants