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

Commit 98dc250

Browse files
author
Sachin Maheshwari
committed
stop back syncing (v4) for task
1 parent a3c0364 commit 98dc250

File tree

1 file changed

+11
-0
lines changed

1 file changed

+11
-0
lines changed

src/services/ProcessorService.js

Lines changed: 11 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -476,6 +476,12 @@ async function processCreate (message) {
476476
logger.debug(`Will skip creating on legacy as status is ${constants.challengeStatuses.New}`)
477477
return
478478
}
479+
480+
if (message.payload.task && message.payload.task.isTask) {
481+
logger.debug(`Will skip creating on legacy for task`)
482+
return
483+
}
484+
479485
const m2mToken = await helper.getM2MToken()
480486

481487
const saveDraftContestDTO = await parsePayload(message.payload, m2mToken)
@@ -572,6 +578,11 @@ processCreate.schema = {
572578
* @param {Object} message the kafka message
573579
*/
574580
async function processUpdate (message) {
581+
if (message.payload.task && message.payload.task.isTask) {
582+
logger.debug(`Will skip creating on legacy for task`)
583+
return
584+
}
585+
575586
let legacyId = message.payload.legacyId
576587
if (message.payload.status === constants.challengeStatuses.New) {
577588
logger.debug(`Will skip creating on legacy as status is ${constants.challengeStatuses.New}`)

0 commit comments

Comments
 (0)