move debug code, fixes reference error

1 files changed, 1 insertions, 1 deletions

diff --git a/worker.js b/worker.js
index 77bbd0c..b9b6948 100644
--- a/worker.js
+++ b/worker.js
@@ -49,6 +49,7 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
             let payload = JSON.parse(msg.content.toString()),
                 notify = msg.properties.headers.notify; // where to send progress report
             await getAPI(payload, notify);
+            logger.info("done", payload);
         } catch (err) {
             // log, move to error queue and NACK on *any* error
             logger.error(err);
@@ -59,7 +60,6 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
             await msg.nack(false, false);
             return;
         }
-        logger.info("done", payload);
         await ch.ack(msg);
     }, { noAck: false });