feat(prism-agent): update pollux to 0.41.0; (#447)

hyperledger · Mar 16, 2023 · f52c5e0 · f52c5e0
1 parent 184838c
commit f52c5e0
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/prism-agent/service/project/Dependencies.scala b/prism-agent/service/project/Dependencies.scala
@@ -10,7 +10,7 @@ object Dependencies {
     val akka = "2.6.20"
     val akkaHttp = "10.2.9"
     val castor = "0.8.1"
-    val pollux = "0.40.0"
+    val pollux = "0.41.0"
     val connect = "0.12.0"
     val bouncyCastle = "1.70"
     val logback = "1.4.5"

diff --git a/...-agent/service/server/src/main/scala/io/iohk/atala/agent/server/jobs/BackgroundJobs.scala b/...-agent/service/server/src/main/scala/io/iohk/atala/agent/server/jobs/BackgroundJobs.scala
@@ -68,6 +68,7 @@ object BackgroundJobs {
       config <- ZIO.service[AppConfig]
       records <- credentialService
         .getIssueCredentialRecordsByStates(
+          ignoreWithZeroRetries = true,
           IssueCredentialRecord.ProtocolState.OfferPending,
           IssueCredentialRecord.ProtocolState.RequestPending,
           IssueCredentialRecord.ProtocolState.RequestGenerated,
@@ -85,6 +86,7 @@ object BackgroundJobs {
       config <- ZIO.service[AppConfig]
       records <- presentationService
         .getPresentationRecordsByStates(
+          ignoreWithZeroRetries = true,
           PresentationRecord.ProtocolState.RequestPending,
           PresentationRecord.ProtocolState.PresentationPending,
           PresentationRecord.ProtocolState.PresentationGenerated,
@@ -753,6 +755,7 @@ object BackgroundJobs {
   private[this] def performPublishCredentialsToDlt(credentialService: CredentialService) = {
     val res: ZIO[Any, CredentialServiceError, Unit] = for {
       records <- credentialService.getIssueCredentialRecordsByStates(
+        ignoreWithZeroRetries = true,
         IssueCredentialRecord.ProtocolState.CredentialPending
       )
       // NOTE: the line below is a potentially slow operation, because <createCredentialPayloadFromRecord> makes a database SELECT call,