mirror of
https://github.com/Infisical/infisical.git
synced 2026-01-09 15:38:03 -05:00
Update secret-rotation-v2-queue.ts
This commit is contained in:
@@ -84,18 +84,16 @@ export const secretRotationV2QueueServiceFactory = async ({
|
|||||||
secretRotationV2DAL,
|
secretRotationV2DAL,
|
||||||
secretRotationV2Service
|
secretRotationV2Service
|
||||||
});
|
});
|
||||||
|
} else {
|
||||||
return;
|
await queueService.queuePg(
|
||||||
|
QueueJobs.SecretRotationV2RotateSecrets,
|
||||||
|
{
|
||||||
|
rotationId: rotation.id,
|
||||||
|
queuedAt: currentTime
|
||||||
|
},
|
||||||
|
getSecretRotationRotateSecretJobOptions(rotation)
|
||||||
|
);
|
||||||
}
|
}
|
||||||
|
|
||||||
await queueService.queuePg(
|
|
||||||
QueueJobs.SecretRotationV2RotateSecrets,
|
|
||||||
{
|
|
||||||
rotationId: rotation.id,
|
|
||||||
queuedAt: currentTime
|
|
||||||
},
|
|
||||||
getSecretRotationRotateSecretJobOptions(rotation)
|
|
||||||
);
|
|
||||||
}
|
}
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
logger.error(error, "secretRotationV2Queue: Queue Rotations Error:");
|
logger.error(error, "secretRotationV2Queue: Queue Rotations Error:");
|
||||||
|
|||||||
Reference in New Issue
Block a user