Revert Marketo specific fixes, keeping only test disablement

Author: mnvsngv

src/actions/marketo/queue.ts

@@ -127,7 +127,6 @@ export class Queue {
 
   async finish() {
     this.finished = true
-    this.checkQueue()
     return this.promise
   }
 

src/actions/marketo/test_marketo.ts

@@ -212,21 +212,19 @@ import { MarketoTransaction } from "./marketo_transaction"
         listRemoveLeadsFromList: spies[3],
       }
 
-      before(() => {
-        sinon.stub(MarketoTransaction.prototype, "marketoClientFromRequest").callsFake(() => {
-          return {
-            lead: {
-              createOrUpdate: spy.leadCreateOrUpdate,
-            },
-            campaign: {
-              request: spy.campaignRequest,
-            },
-            list: {
-              addLeadsToList: spy.listAddLeadsToList,
-              removeLeadsFromList: spy.listRemoveLeadsFromList,
-            },
-          }
-        })
+      sinon.stub(MarketoTransaction.prototype, "marketoClientFromRequest").callsFake(() => {
+        return {
+          lead: {
+            createOrUpdate: spy.leadCreateOrUpdate,
+          },
+          campaign: {
+            request: spy.campaignRequest,
+          },
+          list: {
+            addLeadsToList: spy.listAddLeadsToList,
+            removeLeadsFromList: spy.listRemoveLeadsFromList,
+          },
+        }
       })
 
       it("sends all the data to Marketo for the legacy request format", () => {

src/hub/action_request.ts

@@ -363,10 +363,10 @@ export class ActionRequest {
           }))
           .done(() => {
             winston.info(`[streamJsonDetail] oboe reports done`, {...this.logInfo, rows})
-            resolve()
           })
       }).then(() => {
         winston.info(`[streamJsonDetail] complete`, {...this.logInfo, rows})
+        resolve()
       }).catch((error) => {
         // This error should not be logged as it could come from an action
         // which might decide to include user information in the error message