+0
-3
@@ -291,5 +291,2 @@ "use strict"; | ||
| } | ||
| if (queuedTask.task.scheduledAt && queuedTask.task.scheduledAt > Date.now()) { | ||
| continue; | ||
| } | ||
| queuedTask.processing = true; | ||
@@ -296,0 +293,0 @@ processingSet.add(queuedTask.task.id); |
+0
-6
@@ -99,8 +99,2 @@ import { HookifiedOptions, Hookified } from 'hookified'; | ||
| /** | ||
| * Scheduled time for delayed task execution (milliseconds since epoch) | ||
| * If set, task won't be processed until this time | ||
| * @type {number} | ||
| */ | ||
| scheduledAt?: number; | ||
| /** | ||
| * Headers for additional metadata | ||
@@ -107,0 +101,0 @@ * @type {Record<string, string>} |
+0
-6
@@ -99,8 +99,2 @@ import { HookifiedOptions, Hookified } from 'hookified'; | ||
| /** | ||
| * Scheduled time for delayed task execution (milliseconds since epoch) | ||
| * If set, task won't be processed until this time | ||
| * @type {number} | ||
| */ | ||
| scheduledAt?: number; | ||
| /** | ||
| * Headers for additional metadata | ||
@@ -107,0 +101,0 @@ * @type {Record<string, string>} |
+0
-3
@@ -263,5 +263,2 @@ // src/index.ts | ||
| } | ||
| if (queuedTask.task.scheduledAt && queuedTask.task.scheduledAt > Date.now()) { | ||
| continue; | ||
| } | ||
| queuedTask.processing = true; | ||
@@ -268,0 +265,0 @@ processingSet.add(queuedTask.task.id); |
+2
-10
| { | ||
| "name": "qified", | ||
| "version": "0.7.0", | ||
| "version": "0.8.0", | ||
| "description": "Task and Message Queues with Multiple Providers", | ||
@@ -35,10 +35,2 @@ "type": "module", | ||
| "homepage": "https://github.com/jaredwray/qified#readme", | ||
| "devDependencies": { | ||
| "@biomejs/biome": "^2.3.10", | ||
| "@vitest/coverage-v8": "^4.0.16", | ||
| "rimraf": "^6.1.2", | ||
| "tsup": "^8.5.1", | ||
| "typescript": "^5.9.3", | ||
| "vitest": "^4.0.16" | ||
| }, | ||
| "files": [ | ||
@@ -49,3 +41,3 @@ "dist", | ||
| "dependencies": { | ||
| "hookified": "^1.14.0" | ||
| "hookified": "^1.15.1" | ||
| }, | ||
@@ -52,0 +44,0 @@ "scripts": { |
+6
-6
| [](https://qified.org) | ||
| [](https://github.com/jaredwray/qified/actions/workflows/tests.yaml) | ||
| [](https://github.com/jaredwray/qified/blob/master/LICENSE) | ||
| [](https://github.com/jaredwray/qified/blob/main/LICENSE) | ||
| [](https://codecov.io/gh/jaredwray/qified) | ||
@@ -201,3 +201,3 @@ [](https://npmjs.com/package/qified) | ||
| ## disconnect` | ||
| ## disconnect | ||
@@ -477,6 +477,6 @@ Disconnect from all providers and clean up resources. | ||
| * Memory - this is built into the current `qified` library as `MemoryMessageProvider`. | ||
| * [@qified/redis](packages/redis/README.md) - Redis Provider | ||
| * [@qified/rabbitmq](packages/rabbitmq/README.md) - RabbitMQ Provider | ||
| * [@qified/nats](packages/nats/README.md) - NATS Provider | ||
| * [@qified/zeromq](packages/zeromq/README.md) - ZeroMQ Provider | ||
| * [@qified/redis](../redis/README.md) - Redis Provider | ||
| * [@qified/rabbitmq](../rabbitmq/README.md) - RabbitMQ Provider | ||
| * [@qified/nats](../nats/README.md) - NATS Provider | ||
| * [@qified/zeromq](../zeromq/README.md) - ZeroMQ Provider | ||
@@ -483,0 +483,0 @@ # Development and Testing |
0
-100%97409
-0.85%1854
-0.64%Updated