Skip to content

Commit fb73e20

Browse files
committed
add debug logs
1 parent 47cb8f6 commit fb73e20

1 file changed

Lines changed: 1 addition & 6 deletions

File tree

packages/datadog-instrumentations/src/google-cloud-pubsub.js

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -270,10 +270,7 @@ addHook({ name: '@google-cloud/pubsub', versions: ['>=1.2'], file: 'build/src/le
270270
const ctx = { message }
271271
// Store the context so we can retrieve it in remove()
272272
messageContexts.set(message, ctx)
273-
console.log(`${LOG_PREFIX} Calling receiveStartCh.runStores...`)
274-
const result = receiveStartCh.runStores(ctx, dispense, this, ...arguments)
275-
console.log(`${LOG_PREFIX} receiveStartCh.runStores completed, ctx.currentStore=${!!ctx.currentStore}, ctx.parentStore=${!!ctx.parentStore}`)
276-
return result
273+
return receiveStartCh.runStores(ctx, dispense, this, ...arguments)
277274
} else {
278275
console.log(`${LOG_PREFIX} !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!`)
279276
console.log(`${LOG_PREFIX} !!!!! CRITICAL: NO SUBSCRIBERS ON receiveStartCh !!!!!`)
@@ -295,9 +292,7 @@ addHook({ name: '@google-cloud/pubsub', versions: ['>=1.2'], file: 'build/src/le
295292
if (receiveFinishCh.hasSubscribers) {
296293
// Clean up the stored context
297294
messageContexts.delete(message)
298-
console.log(`${LOG_PREFIX} Calling receiveFinishCh.publish with stored context...`)
299295
receiveFinishCh.publish(ctx)
300-
console.log(`${LOG_PREFIX} receiveFinishCh.publish completed`)
301296
} else {
302297
console.log(`${LOG_PREFIX} WARNING: receiveFinishCh has no subscribers!`)
303298
}

0 commit comments

Comments
 (0)