### Query Documentation API Example Source: https://docs.bullmq.io/bullmq-pro/groups/prioritized.md Demonstrates how to query the documentation dynamically using the `ask` and optional `goal` query parameters via an HTTP GET request. ```http GET https://docs.bullmq.io/bullmq-pro/groups/prioritized.md?ask=&goal= ``` -------------------------------- ### Install BullMQ Source: https://docs.bullmq.io/python/introduction.md Install the BullMQ package using pip. ```bash $ pip install bullmq ``` -------------------------------- ### Install BullMQ with Yarn Source: https://docs.bullmq.io/bull/install.md Use this command to install BullMQ as a project dependency using Yarn. ```bash yarn add bull ``` -------------------------------- ### Worker Setup Source: https://docs.bullmq.io/guide/jobs/stalled.md Basic setup for a BullMQ worker. Ensure the queue name and processor function are correctly defined. ```typescript import { Worker } from 'bullmq'; const worker = new Worker('Paint', painter); ``` -------------------------------- ### Query Documentation Dynamically Source: https://docs.bullmq.io/bull/important-notes.md To get information not directly on the page, make an HTTP GET request to the current URL with `ask` and optional `goal` query parameters. ```http GET https://docs.bullmq.io/bull/important-notes.md?ask=&goal= ``` -------------------------------- ### Install BullMQ with Npm Source: https://docs.bullmq.io/bull/install.md Use this command to install BullMQ as a project dependency using npm. ```bash npm install bull --save ``` -------------------------------- ### Query Documentation Dynamically Source: https://docs.bullmq.io/guide/telemetry/traces.md Perform an HTTP GET request to query the documentation with 'ask' and optional 'goal' parameters. ```http GET https://docs.bullmq.io/guide/telemetry/traces.md?ask=&goal= ``` -------------------------------- ### Querying Documentation Source: https://docs.bullmq.io/guide/flows/remove-dependency.md To get more information or clarification, you can query the documentation dynamically. Perform a GET request to the page URL with `ask` and optional `goal` query parameters. ```http GET https://docs.bullmq.io/guide/flows/remove-dependency.md?ask=&goal= ``` -------------------------------- ### Install bullmq-otel Package Source: https://docs.bullmq.io/guide/telemetry/getting-started.md Add the `bullmq-otel` package to your project using npm. ```bash npm add --save bullmq-otel ``` -------------------------------- ### Querying documentation with GET request Source: https://docs.bullmq.io/guide/flows/adding-bulks.md To get additional information not directly present on the page, perform an HTTP GET request to the page URL with the `ask` query parameter. An optional `goal` parameter can be included to tailor the answer. ```http GET https://docs.bullmq.io/guide/flows/adding-bulks.md?ask=&goal= ``` -------------------------------- ### HTTP GET Request for Documentation Query Source: https://docs.bullmq.io/rust/introduction.md To get additional information not directly present on the page, perform an HTTP GET request with the 'ask' query parameter. The optional 'goal' parameter can tailor the answer to a broader objective. ```http GET https://docs.bullmq.io/rust/introduction.md?ask=&goal= ``` -------------------------------- ### Querying Documentation API Source: https://docs.bullmq.io/bull/patterns/message-queue.md Demonstrates how to query the documentation dynamically using an HTTP GET request with 'ask' and optional 'goal' parameters. ```http GET https://docs.bullmq.io/bull/patterns/message-queue.md?ask=&goal= ``` -------------------------------- ### Install NestJS BullMQ Package Source: https://docs.bullmq.io/guide/nestjs.md Install the official NestJS BullMQ package using npm. ```bash npm i @nestjs/bullmq ``` -------------------------------- ### Install BullMQ TypeScript Definitions with Npm Source: https://docs.bullmq.io/bull/install.md Install the TypeScript definitions for BullMQ as a development dependency using npm. ```bash npm install @types/bull --save-dev ``` -------------------------------- ### Query Documentation with GET Request Source: https://docs.bullmq.io/bullmq-pro/changelog/changelog-v2.md Use this endpoint to dynamically query the documentation. Provide your question in the 'ask' parameter and an optional broader goal in the 'goal' parameter. ```bash GET https://docs.bullmq.io/bullmq-pro/changelog/changelog-v2.md?ask=&goal= ``` -------------------------------- ### Query Documentation with GET Request Source: https://docs.bullmq.io/python/changelog/changelog-v0.md To get additional information not directly present on the page, perform an HTTP GET request to the current page URL with the `ask` query parameter. The optional `goal` parameter can be used to tailor the answer to a broader objective. ```http GET https://docs.bullmq.io/python/changelog/changelog-v0.md?ask=&goal= ``` -------------------------------- ### Start Jaeger with Docker Compose Source: https://docs.bullmq.io/guide/telemetry/running-jaeger.md Command to start the Jaeger service defined in the docker-compose.yaml file. ```bash docker-compose up ``` -------------------------------- ### Install BullMQ Pro Package Source: https://docs.bullmq.io/bullmq-pro/install.md Install the BullMQ Pro package using your preferred package manager after configuring your .npmrc file. ```bash yarn add @taskforcesh/bullmq-pro ``` -------------------------------- ### Install BullMQ TypeScript Definitions with Yarn Source: https://docs.bullmq.io/bull/install.md Install the TypeScript definitions for BullMQ as a development dependency using Yarn. ```bash yarn add --dev @types/bull ``` -------------------------------- ### Install NestJS BullMQ Pro Module Source: https://docs.bullmq.io/bullmq-pro/nestjs.md Install the necessary package for NestJS integration using yarn. ```bash yarn add @taskforcesh/nestjs-bullmq-pro ``` -------------------------------- ### Composer JSON for Release Installation Source: https://docs.bullmq.io/php/introduction.md Configure Composer to use a local path for the BullMQ PHP release and specify the package for installation. ```json { "repositories": [ { "type": "path", "url": "./bullmq-php-X.X.X" } ], "require": { "taskforcesh/bullmq-php": "*" } } ``` -------------------------------- ### Querying Documentation with GET Request Source: https://docs.bullmq.io/guide/job-schedulers/repeat-strategies.md You can query this documentation dynamically by performing an HTTP GET request to the current page URL with the `ask` query parameter and an optional `goal` query parameter. This is useful for retrieving information not explicitly present on the page or for clarification. ```http GET https://docs.bullmq.io/guide/job-schedulers/repeat-strategies.md?ask=&goal= ``` -------------------------------- ### Query Documentation with GET Request Source: https://docs.bullmq.io/guide/job-schedulers/repeat-options.md Use this method to ask questions about the documentation. Provide a specific question in the 'ask' parameter and an optional broader goal in the 'goal' parameter. ```http GET https://docs.bullmq.io/guide/job-schedulers/repeat-options.md?ask=&goal= ``` -------------------------------- ### Querying Documentation with GitBook Source: https://docs.bullmq.io/php/introduction.md To get information not explicitly on the page, make a GET request to the page URL with the 'ask' query parameter for your question and an optional 'goal' parameter for broader context. ```http GET https://docs.bullmq.io/php/introduction.md?ask=&goal= ``` -------------------------------- ### Querying Documentation Source: https://docs.bullmq.io/bull/introduction.md To get information not directly on a page, make an HTTP GET request to the page URL with the 'ask' query parameter for your question and an optional 'goal' parameter for your broader objective. GitBook uses the goal to provide more tailored answers. ```http GET https://docs.bullmq.io/bull/introduction.md?ask=&goal= ``` -------------------------------- ### Query Documentation Dynamically Source: https://docs.bullmq.io/bullmq-pro/changelog/changelog-v1.md Perform an HTTP GET request to query the documentation dynamically. Use the `ask` parameter for your question and optionally the `goal` parameter for broader context. ```http GET https://docs.bullmq.io/bullmq-pro/changelog/changelog-v1.md?ask=&goal= ``` -------------------------------- ### Querying Documentation API Source: https://docs.bullmq.io/guide/nestjs/queue-events-listeners.md To get information not explicitly on the page, make a GET request to the page URL with 'ask' and optional 'goal' query parameters. ```http GET https://docs.bullmq.io/guide/nestjs/queue-events-listeners.md?ask=&goal= ``` -------------------------------- ### Start a BullMQ Worker Source: https://docs.bullmq.io/elixir/introduction.md Start a worker process using BullMQ.Worker.start_link/1, specifying the queue, connection, processor function, concurrency, and optional callbacks like on_completed. ```elixir # Start the worker {:ok, worker} = BullMQ.Worker.start_link( queue: "emails", connection: :my_redis, processor: &MyApp.EmailWorker.process/1, concurrency: 5, on_completed: fn job, result -> Logger.info("Job #{job.id} completed") end ) ``` -------------------------------- ### Composer JSON for GitHub Installation Source: https://docs.bullmq.io/php/introduction.md Configure Composer to install the BullMQ PHP package directly from its GitHub repository for development purposes. Set minimum stability to 'dev' and prefer stable packages. ```json { "repositories": [ { "type": "vcs", "url": "https://github.com/taskforcesh/bullmq" } ], "require": { "taskforcesh/bullmq-php": "dev-master" }, "minimum-stability": "dev", "prefer-stable": true } ``` -------------------------------- ### Query Documentation Dynamically Source: https://docs.bullmq.io/bullmq-pro/changelog/changelog-v5.md Perform an HTTP GET request to query the documentation dynamically. Use the 'ask' parameter for your question and optionally the 'goal' parameter for your end goal. ```http GET https://docs.bullmq.io/bullmq-pro/changelog/changelog-v5.md?ask=&goal= ``` -------------------------------- ### Querying Documentation Dynamically Source: https://docs.bullmq.io/guide/queues/removing-jobs.md You can query the documentation dynamically by performing an HTTP GET request on the current page URL with the `ask` query parameter and an optional `goal` parameter. ```http GET https://docs.bullmq.io/guide/queues/removing-jobs.md?ask=&goal= ``` -------------------------------- ### Querying Documentation via HTTP GET Source: https://docs.bullmq.io/bullmq-pro/nestjs/producers.md Use this mechanism to query documentation dynamically when information is not directly available on the page. Include your question in the `ask` query parameter. ```http GET https://docs.bullmq.io/bullmq-pro/nestjs/producers.md?ask=&goal= ``` -------------------------------- ### Get Jobs in Python Source: https://docs.bullmq.io/guide/jobs/getters.md Fetch jobs from a given status with pagination. This example retrieves the oldest 100 completed jobs. ```python completed = await myQueue.getJobs(['completed'], 0, 100, True) # returns the oldest 100 jobs ``` -------------------------------- ### Launch Producer and Consumer with Node.js Source: https://docs.bullmq.io/guide/telemetry/running-a-simple-example.md Alternatively, use the Node.js runtime to launch services with OTLP instrumentation if using JavaScript or compiled TypeScript. ```bash node --import producer.inst.otlp.js producer.js ``` ```bash node --import consumer.inst.otlp.js consumer.js ``` -------------------------------- ### Stop Deduplication When Job is Active Source: https://docs.bullmq.io/patterns/deduplication.md Call `removeDeduplicationKey` within the worker to stop deduplicating a job once it has started processing. This example uses simple mode for deduplication. ```typescript import { Job, Queue, Worker } from 'bullmq'; const myQueue = new Queue('Paint'); const worker = new Worker('Paint', async (job: Job) => { await job.removeDeduplicationKey(); console.log('Do something with job'); return 'some value'; }); myQueue.add('house', { color: 'white' }, { deduplication: { id: 'house' } }); ``` -------------------------------- ### Query Documentation Dynamically Source: https://docs.bullmq.io/elixir/introduction.md Use the `ask` query parameter to ask questions about the documentation. The optional `goal` parameter can be used to tailor the answer. ```http GET https://docs.bullmq.io/elixir/introduction.md?ask=&goal= ``` -------------------------------- ### Rust: Retry a Job Source: https://docs.bullmq.io/guide/jobs/retrying-job.md Provides an example of retrying jobs in Rust. It covers getting a job by its ID and then retrying it, specifying either 'failed' or 'completed' as the state. ```rust use bullmq::{Queue, QueueOptions, Job}; use bullmq::types::RetryOptions; let queue = Queue::new("my-queue", QueueOptions::default()).await?; // Get a failed job by ID let mut job = queue.get_job("job-id").await?.unwrap(); // Retry a failed job (default state is "failed") job.retry("failed", None).await?; // Retry a completed job job.retry("completed", None).await?; ``` -------------------------------- ### Querying Documentation with Ask and Goal Parameters Source: https://docs.bullmq.io/bullmq-pro/nestjs/changelog.md Perform an HTTP GET request to query the documentation dynamically. Use the 'ask' parameter for specific questions and the optional 'goal' parameter for broader objectives. ```http GET https://docs.bullmq.io/bullmq-pro/nestjs/changelog.md?ask=&goal= ``` -------------------------------- ### Query Documentation with Parameters Source: https://docs.bullmq.io/bull/patterns/redis-cluster.md Perform an HTTP GET request to the documentation URL with `ask` and optional `goal` query parameters to dynamically query the documentation. Use this for clarification or to retrieve related information. ```http GET https://docs.bullmq.io/bull/patterns/redis-cluster.md?ask=&goal= ``` -------------------------------- ### Query Documentation Dynamically Source: https://docs.bullmq.io/bull/quick-guide.md Perform an HTTP GET request with 'ask' and optional 'goal' query parameters to dynamically query the documentation. Use this when the answer is not explicitly present or for clarification. ```bash GET https://docs.bullmq.io/bull/quick-guide.md?ask=&goal= ``` -------------------------------- ### Query Documentation Dynamically Source: https://docs.bullmq.io/guide/queues/meta.md To ask questions about the documentation, perform an HTTP GET request to the page URL with `ask` and optional `goal` query parameters. This is useful for retrieving information not explicitly present on the current page. ```http GET https://docs.bullmq.io/guide/queues/meta.md?ask=&goal= ``` -------------------------------- ### Pre-configuring Metrics with Custom Options Source: https://docs.bullmq.io/guide/telemetry/metrics.md Demonstrates how to initialize BullMQOtel and pre-configure a counter, a histogram, and a gauge with custom descriptions and units. This setup ensures BullMQ uses these custom metric configurations. ```typescript import { BullMQOtel } from 'bullmq-otel'; import { Queue, Worker } from 'bullmq'; const telemetry = new BullMQOtel({ tracerName: 'my-app', meterName: 'my-app', version: '1.0.0', enableMetrics: true, }); // Pre-configure a counter with custom options // This will be reused by BullMQ, ignoring its default options telemetry.meter.createCounter('bullmq.jobs.completed', { description: 'Custom description for completed jobs', unit: '1', }); // Pre-configure the duration histogram with custom options telemetry.meter.createHistogram('bullmq.job.duration', { description: 'Custom job processing duration', unit: 's', // Using seconds instead of default milliseconds }); // Pre-configure a gauge for queue job counts telemetry.meter.createGauge('bullmq.queue.jobs', { description: 'Current number of jobs in the queue by state', unit: '{jobs}', }); const queue = new Queue('myQueue', { connection: { host: '127.0.0.1', port: 6379, }, telemetry, }); const worker = new Worker( 'myQueue', async job => { return 'some value'; }, { connection: { host: '127.0.0.1', port: 6379, }, telemetry, }, ); // When calling recordJobCountsMetric(), gauge metrics are recorded const jobCounts = await queue.recordJobCountsMetric(); ``` -------------------------------- ### Query Documentation Dynamically Source: https://docs.bullmq.io/bull Perform an HTTP GET request to query the documentation. Use the `ask` parameter for your question and optionally the `goal` parameter to specify your end goal. ```http GET https://docs.bullmq.io/bull.md?ask=&goal= ``` -------------------------------- ### Querying Documentation Dynamically Source: https://docs.bullmq.io/patterns/manual-retrying.md Use this HTTP GET request to ask questions about the documentation dynamically. The `ask` parameter is for the specific question, and the optional `goal` parameter helps tailor the answer to a broader objective. ```http GET https://docs.bullmq.io/patterns/manual-retrying.md?ask=&goal= ``` -------------------------------- ### Query Documentation via HTTP GET Source: https://docs.bullmq.io/changelog/changelog-v2.md Use this endpoint to dynamically query the documentation. Include your specific question in the 'ask' parameter and optionally provide a broader 'goal' to tailor the response. The response includes a direct answer and relevant sources. ```http GET https://docs.bullmq.io/changelog/changelog-v2.md?ask=&goal= ``` -------------------------------- ### Query Documentation with GitBook Source: https://docs.bullmq.io/bull/install.md Perform an HTTP GET request to query the documentation dynamically. Use the 'ask' parameter for your question and optionally the 'goal' parameter for your end goal. ```http GET https://docs.bullmq.io/bull/install.md?ask=&goal= ``` -------------------------------- ### Query Documentation with `ask` and `goal` Parameters Source: https://docs.bullmq.io/guide/flows.md When the answer is not explicitly present, use this mechanism to query the documentation dynamically. The `ask` parameter specifies the question, and the optional `goal` parameter refines the answer towards a broader objective. ```http GET https://docs.bullmq.io/guide/flows.md?ask=&goal= ``` -------------------------------- ### Set Job Scheduler Start Date Source: https://docs.bullmq.io/guide/job-schedulers/repeat-options.md Use startDate to define a future date from which a job will begin repeating. This ensures jobs only start scheduling on or after the specified date. ```typescript const { Queue } = require('bullmq'); const connection = { host: 'localhost', port: 6379 }; const myQueue = new Queue('my-dated-jobs', { connection }); await myQueue.upsertJobScheduler( 'start-later-job', { every: 60000, // every minute startDate: new Date('2024-10-15T00:00:00Z'), // start on October 15, 2024 }, { name: 'timed-start-job', data: { message: 'Starting later' }, }, ); ``` -------------------------------- ### Query Documentation via HTTP GET Source: https://docs.bullmq.io/changelog/changelog-v3.md Use this endpoint to dynamically query the documentation. The 'ask' parameter is mandatory for specifying your question, while 'goal' is optional for providing broader context to tailor the response. ```http GET https://docs.bullmq.io/changelog/changelog-v3.md?ask=&goal= ``` -------------------------------- ### Get Rate Limit TTL Source: https://docs.bullmq.io/guide/queues/global-rate-limit.md Gets the current Time To Live (TTL) for the rate limit, indicating how long the current rate limit settings will be active before potentially resetting. ```typescript const ttl = await queue.getRateLimitTtl(); ``` -------------------------------- ### Get Total Jobs Count in Groups Source: https://docs.bullmq.io/bullmq-pro/groups/getters.md Use this to get the total number of jobs across multiple groups. Specify the maximum number of groups to iterate over in a single call. ```typescript import { QueuePro } from '@taskforcesh/bullmq-pro'; const queue = new QueuePro('myQueue', { connection }); const groupId = 'my group'; const count = await queue.getGroupsJobsCount(1000); // 1000 groups in each iteration ``` -------------------------------- ### Query Documentation Dynamically Source: https://docs.bullmq.io/bullmq-pro/changelog.md Perform an HTTP GET request to query the documentation dynamically. Use the `ask` parameter for your question and optionally the `goal` parameter to specify your end goal. ```http GET https://docs.bullmq.io/bullmq-pro/changelog.md?ask=&goal= ``` -------------------------------- ### Querying Documentation Source: https://docs.bullmq.io/guide/queuescheduler.md Use this mechanism to query the documentation dynamically by asking a question with the `ask` query parameter and an optional `goal` parameter. ```http GET https://docs.bullmq.io/guide/queuescheduler.md?ask=&goal= ``` -------------------------------- ### Start Stalled Job Checker Source: https://docs.bullmq.io/patterns/manually-fetching-jobs.md Manually start the stalled job checker to move jobs whose locks have expired back to the 'wait' status. This checker runs periodically based on the stalledInterval option. ```typescript await worker.startStalledCheckTimer() ``` -------------------------------- ### Querying Documentation with GET Request Source: https://docs.bullmq.io/guide/telemetry/running-a-simple-example.md Use this method to ask specific questions or retrieve broader context from the documentation. The 'ask' parameter is mandatory for the question, and 'goal' is optional for specifying the end objective. ```http GET https://docs.bullmq.io/guide/telemetry/running-a-simple-example.md?ask=&goal= ``` -------------------------------- ### Query Documentation Dynamically Source: https://docs.bullmq.io/guide/job-schedulers/manage-job-schedulers.md Perform an HTTP GET request on the current page URL with the `ask` query parameter and an optional `goal` query parameter to query the documentation dynamically. Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections. ```http GET https://docs.bullmq.io/guide/job-schedulers/manage-job-schedulers.md?ask=&goal= ``` -------------------------------- ### Retry, Promote, and Get Counts with BullMQ PHP Source: https://docs.bullmq.io/php/introduction.md Use this code to retry failed or completed jobs, promote delayed jobs to the waiting state, and get counts of jobs grouped by priority. Specify the maximum number of jobs to process per iteration. ```php retryJobs([ 'count' => 100, // Max jobs to retry per iteration (default: 1000) 'state' => 'failed', // State to retry from: 'failed' or 'completed' ]); // Promote all delayed jobs to waiting $queue->promoteJobs(['count' => 100]); // Get counts by priority $counts = $queue->getCountsPerPriority([0, 1, 2, 3]); ``` -------------------------------- ### Query Documentation via HTTP GET Source: https://docs.bullmq.io/guide/connections.md Use this method to ask questions about the documentation when the answer is not explicitly present on the page. The 'ask' parameter contains your specific question, and the optional 'goal' parameter helps tailor the response to your broader objective. ```http GET https://docs.bullmq.io/guide/connections.md?ask=&goal= ``` -------------------------------- ### Get Group Jobs Source: https://docs.bullmq.io/bullmq-pro/groups/getters.md Retrieves jobs from a specific group with pagination. ```APIDOC ## Get Group Jobs ### Description Retrieves jobs from a specific group with pagination. ### Method `getGroupJobs(groupId: string, start: number, end: number)` ### Parameters #### Path Parameters None #### Query Parameters None #### Request Body None ### Request Example ```typescript const groupId = 'my group'; const jobs = await queue.getGroupJobs(groupId, 0, 100); ``` ### Response #### Success Response (200) - **jobs** (Array) - An array of job objects within the specified range. #### Response Example ```json { "jobs": [ { "id": "job-1", "name": "myJob", "data": {}, "status": "completed" }, { "id": "job-2", "name": "anotherJob", "data": {}, "status": "active" } ] } ``` ``` -------------------------------- ### BullMQOtel Constructor: Old vs. New Signature Source: https://docs.bullmq.io/guide/telemetry/metrics.md Demonstrates the original constructor signature for backward compatibility (traces only) and the new style with an options object for traces and optional metrics. ```typescript // Old style (traces only) const telemetry = new BullMQOtel('my-app', '1.0.0'); // New style with options object (traces + optional metrics) const telemetry = new BullMQOtel({ tracerName: 'my-app', version: '1.0.0', enableMetrics: true, }); ``` -------------------------------- ### Get All Children Values for a Job Source: https://docs.bullmq.io/guide/flows.md Retrieves all the values produced by the children of a given job. ```typescript const values = await job.getChildrenValues(); ``` -------------------------------- ### Get Group Active Count Source: https://docs.bullmq.io/bullmq-pro/groups/getters.md Retrieves the number of active jobs within a specific group. ```APIDOC ## Get Group Active Count ### Description Retrieves the number of active jobs within a specific group. ### Method `getGroupActiveCount(groupId: string)` ### Parameters #### Path Parameters None #### Query Parameters None #### Request Body None ### Request Example ```typescript const groupId = 'my group'; const activeCount = await queue.getGroupActiveCount(groupId); ``` ### Response #### Success Response (200) - **activeCount** (number) - The number of active jobs in the specified group. #### Response Example ```json { "activeCount": 50 } ``` ``` -------------------------------- ### Get a Specific Job Scheduler Source: https://docs.bullmq.io/guide/job-schedulers/manage-job-schedulers.md Retrieve a job scheduler by its ID. This is invaluable for inspecting dedicated configurations. ```typescript const scheduler = await queue.getJobScheduler('test'); console.log('Current job scheduler:', scheduler); ``` -------------------------------- ### Query Documentation with HTTP GET Source: https://docs.bullmq.io/bullmq-pro/introduction.md Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections. 'ask' is the immediate question, and 'goal' is optional and describes the broader end goal. ```http GET https://docs.bullmq.io/bullmq-pro/introduction.md?ask=&goal= ``` -------------------------------- ### Query Documentation API Source: https://docs.bullmq.io/guide/jobs/lifo.md To ask questions about the documentation, perform a GET request to the page URL with the `ask` query parameter. An optional `goal` parameter can be included to tailor the response. ```http GET https://docs.bullmq.io/guide/jobs/lifo.md?ask=&goal= ``` -------------------------------- ### Painter Processor Function Source: https://docs.bullmq.io/guide/jobs/stalled.md Example of a processor function for a BullMQ worker. This function will be executed when a job is processed. ```typescript export default = (job) => { // Paint something } ``` -------------------------------- ### Query Documentation Dynamically Source: https://docs.bullmq.io/elixir Use this mechanism to ask questions about the documentation when information is not explicitly present. The 'goal' parameter helps tailor the answer to a broader objective. ```http GET https://docs.bullmq.io/elixir.md?ask=&goal= ``` -------------------------------- ### Get All Dependency Counts for a Job Source: https://docs.bullmq.io/guide/flows.md Retrieves the counts of failed, ignored, processed, and unprocessed dependencies for a given job. ```typescript const { failed, ignored, processed, unprocessed } = await job.getDependenciesCount(); ``` -------------------------------- ### Configure NPM Registry and Token Source: https://docs.bullmq.io/bullmq-pro/install.md Set up your .npmrc file to use the taskforce.sh registry and authenticate with your NPM token. Ensure NPM_TASKFORCESH_TOKEN is set as an environment variable. ```bash @taskforcesh:registry=https://npm.taskforce.sh/ //npm.taskforce.sh/:_authToken=${NPM_TASKFORCESH_TOKEN} always-auth=true ``` -------------------------------- ### Get Groups Jobs Count Source: https://docs.bullmq.io/bullmq-pro/groups/getters.md Retrieves the total number of jobs across all groups, processing groups in batches. ```APIDOC ## Get Groups Jobs Count ### Description Retrieves the total number of jobs across all groups, processing groups in batches. ### Method `getGroupsJobsCount(batchSize: number)` ### Parameters #### Path Parameters None #### Query Parameters None #### Request Body None ### Request Example ```typescript import { QueuePro } from '@taskforcesh/bullmq-pro'; const queue = new QueuePro('myQueue', { connection }); const count = await queue.getGroupsJobsCount(1000); // 1000 groups in each iteration ``` ### Response #### Success Response (200) - **count** (number) - The total number of jobs across all groups. #### Response Example ```json { "count": 15000 } ``` ```