Add async-await example

actumn · actumn · commit 51fc215dbf88 · 2020-03-20T11:56:04.000+09:00
diff --git a/examples/async-await/client.js b/examples/async-await/client.js
@@ -0,0 +1,16 @@
+"use strict";
+const celery = require("../../dist");
+
+const client = celery.createClient("redis://", "redis://");
+// client.conf.TASK_PROTOCOL = 1;
+
+const task = client.createTask("delay_job");
+
+async function main() {
+  const result = task.applyAsync();
+  const data= await result.get();
+  console.log(data);
+  await client.disconnect();
+} 
+
+main();
diff --git a/examples/async-await/worker.js b/examples/async-await/worker.js
@@ -0,0 +1,15 @@
+"use strict";
+const celery = require('../../dist');
+const worker = celery.createWorker("redis://", "redis://");
+
+worker.register("delay_job", async () => {
+  const delayTime = 1000;
+
+  await new Promise((resolve, reject) => {
+    setTimeout(resolve, delayTime);
+  })
+  return {
+    delayTime
+  }
+});
+worker.start();
diff --git a/examples/tutorial-redis/python-celery/worker.sh b/examples/tutorial-redis/python-celery/worker.sh
@@ -0,0 +1 @@
+celery worker -A tasks --loglevel=INFO
diff --git a/examples/tutorial/python-celery/worker.sh b/examples/tutorial/python-celery/worker.sh
@@ -0,0 +1 @@
+celery worker -A tasks --loglevel=INFO
