We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 3252996 commit b2e3410Copy full SHA for b2e3410
.gitignore
@@ -9,4 +9,6 @@ lib-cov
9
logs
10
node_modules
11
temp
12
-*.env
+*.env
13
+
14
+packages/orap/examples/testDemo/*
packages/orap/src/verse/task.ts
@@ -1,3 +1,4 @@
1
+import { sleep } from '@murongg/utils'
2
import type { TaskFlow } from '../flow/task'
3
import { TaskRaplized } from '../task/verse'
4
import type { Verse } from './interface'
@@ -41,6 +42,9 @@ export class TaskVerse implements Verse {
41
42
await task.loadByKey(key)
43
await task.handle()
44
}
45
46
+ // sleep for 1 second for avoiding too many requests and ensure the task is finished
47
+ await sleep(1000)
48
// get all task keys again
49
keys = await this.flow.sm.keys(`${prefix}*`)
50
0 commit comments