Skip to content
This repository was archived by the owner on Jan 23, 2025. It is now read-only.

Commit d533af9

Browse files
Update so it uses legacy.pureV5Task
1 parent 98dc250 commit d533af9

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/services/ProcessorService.js

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -477,8 +477,8 @@ async function processCreate (message) {
477477
return
478478
}
479479

480-
if (message.payload.task && message.payload.task.isTask) {
481-
logger.debug(`Will skip creating on legacy for task`)
480+
if (_.get(message, 'payload.legacy.pureV5Task')) {
481+
logger.debug('Challenge is a pure v5 task. Will skip...')
482482
return
483483
}
484484

@@ -578,8 +578,8 @@ processCreate.schema = {
578578
* @param {Object} message the kafka message
579579
*/
580580
async function processUpdate (message) {
581-
if (message.payload.task && message.payload.task.isTask) {
582-
logger.debug(`Will skip creating on legacy for task`)
581+
if (_.get(message, 'payload.legacy.pureV5Task')) {
582+
logger.debug('Challenge is a pure v5 task. Will skip...')
583583
return
584584
}
585585

0 commit comments

Comments
 (0)