Skip to content

Commit 301e0fb

Browse files
chore(release): 1.18.0 [skip ci]
# [1.18.0](v1.17.0...v1.18.0) (2021-04-16) ### Features * add remove support for flows ([4e8a7ef](4e8a7ef))
1 parent 4e8a7ef commit 301e0fb

11 files changed

+86
-4
lines changed

docs/gitbook/CHANGELOG.md

+7
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,10 @@
1+
# [1.18.0](https://github.com/taskforcesh/bullmq/compare/v1.17.0...v1.18.0) (2021-04-16)
2+
3+
4+
### Features
5+
6+
* add remove support for flows ([4e8a7ef](https://github.com/taskforcesh/bullmq/commit/4e8a7efd53f918937478ae13f5da7dee9ea9d8b3))
7+
18
# [1.17.0](https://github.com/taskforcesh/bullmq/compare/v1.16.2...v1.17.0) (2021-04-16)
29

310

docs/gitbook/api/bullmq.flow.add.md

+1-1
Original file line numberDiff line numberDiff line change
@@ -24,5 +24,5 @@ add(flow: FlowJob): Promise<JobNode>;
2424

2525
<b>Returns:</b>
2626

27-
Promise&lt;JobNode&gt;
27+
Promise&lt;[JobNode](./bullmq.jobnode.md)<!-- -->&gt;
2828

Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
<!-- Do not edit this file. It is automatically generated by API Documenter. -->
2+
3+
[Home](./index.md) &gt; [bullmq](./bullmq.md) &gt; [JobNode](./bullmq.jobnode.md) &gt; [children](./bullmq.jobnode.children.md)
4+
5+
## JobNode.children property
6+
7+
<b>Signature:</b>
8+
9+
```typescript
10+
children?: JobNode[];
11+
```
+11
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,11 @@
1+
<!-- Do not edit this file. It is automatically generated by API Documenter. -->
2+
3+
[Home](./index.md) &gt; [bullmq](./bullmq.md) &gt; [JobNode](./bullmq.jobnode.md) &gt; [job](./bullmq.jobnode.job.md)
4+
5+
## JobNode.job property
6+
7+
<b>Signature:</b>
8+
9+
```typescript
10+
job: Job;
11+
```

docs/gitbook/api/bullmq.jobnode.md

+19
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,19 @@
1+
<!-- Do not edit this file. It is automatically generated by API Documenter. -->
2+
3+
[Home](./index.md) &gt; [bullmq](./bullmq.md) &gt; [JobNode](./bullmq.jobnode.md)
4+
5+
## JobNode interface
6+
7+
<b>Signature:</b>
8+
9+
```typescript
10+
export interface JobNode
11+
```
12+
13+
## Properties
14+
15+
| Property | Type | Description |
16+
| --- | --- | --- |
17+
| [children?](./bullmq.jobnode.children.md) | [JobNode](./bullmq.jobnode.md)<!-- -->\[\] | <i>(Optional)</i> |
18+
| [job](./bullmq.jobnode.job.md) | [Job](./bullmq.job.md) | |
19+

docs/gitbook/api/bullmq.md

+1
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@
3737
| [BackoffOptions](./bullmq.backoffoptions.md) | Settings for backing off failed jobs. |
3838
| [ChildProcessExt](./bullmq.childprocessext.md) | |
3939
| [JobJson](./bullmq.jobjson.md) | |
40+
| [JobNode](./bullmq.jobnode.md) | |
4041
| [JobsOptions](./bullmq.jobsoptions.md) | |
4142
| [QueueBaseOptions](./bullmq.queuebaseoptions.md) | |
4243
| [QueueEvents](./bullmq.queueevents.md) | |

docs/gitbook/api/bullmq.parentopts.md

+1
Original file line numberDiff line numberDiff line change
@@ -10,5 +10,6 @@
1010
export declare type ParentOpts = {
1111
waitChildrenKey?: string;
1212
parentDependenciesKey?: string;
13+
parentKey?: string;
1314
};
1415
```

docs/gitbook/api/bullmq.queue.getrepeatablejobs.md

+7-2
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,12 @@ getRepeatableJobs(start?: number, end?: number, asc?: boolean): Promise<{
1111
key: string;
1212
name: string;
1313
id: string;
14-
endDate: number;
14+
endDate: number; /**
15+
* Drains the queue, i.e., removes all jobs that are waiting
16+
* or delayed, but not active, completed or failed.
17+
*
18+
* TODO: Convert to an atomic LUA script.
19+
*/
1520
tz: string;
1621
cron: string;
1722
next: number;
@@ -28,5 +33,5 @@ getRepeatableJobs(start?: number, end?: number, asc?: boolean): Promise<{
2833

2934
<b>Returns:</b>
3035

31-
Promise&lt;{ key: string; name: string; id: string; endDate: number; tz: string; cron: string; next: number; }\[\]&gt;
36+
Promise&lt;{ key: string; name: string; id: string; endDate: number; /\*\* \* Drains the queue, i.e., removes all jobs that are waiting \* or delayed, but not active, completed or failed. \* \* TODO: Convert to an atomic LUA script. \*/ tz: string; cron: string; next: number; }\[\]&gt;
3237

docs/gitbook/api/bullmq.queue.md

+1
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@ export declare class Queue<T = any, R = any, N extends string = string> extends
3939
| [isPaused()](./bullmq.queue.ispaused.md) | | |
4040
| [obliterate(opts)](./bullmq.queue.obliterate.md) | | |
4141
| [pause()](./bullmq.queue.pause.md) | | Pauses the processing of this queue globally.<!-- -->We use an atomic RENAME operation on the wait queue. Since we have blocking calls with BRPOPLPUSH on the wait queue, as long as the queue is renamed to 'paused', no new jobs will be processed (the current ones will run until finalized).<!-- -->Adding jobs requires a LUA script to check first if the paused list exist and in that case it will add it there instead of the wait list. |
42+
| [remove(jobId)](./bullmq.queue.remove.md) | | Removes the given job from the queue as well as all its dependencies. |
4243
| [removeRepeatable(name, repeatOpts, jobId)](./bullmq.queue.removerepeatable.md) | | |
4344
| [removeRepeatableByKey(key)](./bullmq.queue.removerepeatablebykey.md) | | |
4445
| [resume()](./bullmq.queue.resume.md) | | |
+26
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
<!-- Do not edit this file. It is automatically generated by API Documenter. -->
2+
3+
[Home](./index.md) &gt; [bullmq](./bullmq.md) &gt; [Queue](./bullmq.queue.md) &gt; [remove](./bullmq.queue.remove.md)
4+
5+
## Queue.remove() method
6+
7+
Removes the given job from the queue as well as all its dependencies.
8+
9+
<b>Signature:</b>
10+
11+
```typescript
12+
remove(jobId: string): Promise<any>;
13+
```
14+
15+
## Parameters
16+
17+
| Parameter | Type | Description |
18+
| --- | --- | --- |
19+
| jobId | string | The if of the job to remove |
20+
21+
<b>Returns:</b>
22+
23+
Promise&lt;any&gt;
24+
25+
1 if it managed to remove the job or -1 if the job or any of its dependencies was locked.
26+

package.json

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "bullmq",
3-
"version": "1.17.0",
3+
"version": "1.18.0",
44
"description": "Queue for messages and jobs based on Redis",
55
"main": "dist/index.js",
66
"types": "dist/index.d.ts",

0 commit comments

Comments
 (0)