diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-13 15:21:49 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-13 15:21:49 +0200 |
| commit | ee5873da3d2167a38e9f5b77fbb5f9a04ce8d781 (patch) | |
| tree | 630d9e8371cba48f39d4de217c2f5c090d18e95d | |
| parent | c2fbfa06eb48240033c22ffedac0afd425199348 (diff) | |
| download | apigrabber-ee5873da3d2167a38e9f5b77fbb5f9a04ce8d781.tar.gz apigrabber-ee5873da3d2167a38e9f5b77fbb5f9a04ce8d781.zip | |
notify for grab_done at the end instead of grab_fail
| -rw-r--r-- | worker.js | 4 |
1 files changed, 2 insertions, 2 deletions
@@ -102,14 +102,14 @@ if (MADGLORY_TOKEN == undefined) throw "Need an API token"; } console.log(err.statusCode); failed = true; - await ch.publish("amq.topic", notify, - new Buffer("grab_failed")); } // next page if (!failed) payload.params["page[offset]"] += payload.params["page[limit]"] } + await ch.publish("amq.topic", notify, + new Buffer("grab_done")); } // download a sample ZIP and send to processor |
