From 8c8854e66e5e1bc86243d3b3c35ceccf75b9d3a0 Mon Sep 17 00:00:00 2001 From: Aadit Chugh Date: Thu, 11 Jul 2024 12:30:16 +0530 Subject: [PATCH] ADAPT1-1599 | set the default value --- .../src/main/scala/hydra/avro/registry/SchemaRegistry.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/avro/src/main/scala/hydra/avro/registry/SchemaRegistry.scala b/avro/src/main/scala/hydra/avro/registry/SchemaRegistry.scala index 9c73d2da2..7666c6b86 100644 --- a/avro/src/main/scala/hydra/avro/registry/SchemaRegistry.scala +++ b/avro/src/main/scala/hydra/avro/registry/SchemaRegistry.scala @@ -194,19 +194,19 @@ object SchemaRegistry { } def test[F[_] : Sync : Logger : Sleep]: F[SchemaRegistry[F]] = Sync[F].delay { - getFromSchemaRegistryClient(new MockSchemaRegistryClient, schemaRegistryClientRetries = 0, schemaRegistryClientRetriesDelay = 1.milliseconds, useExponentialBackoff = false) + getFromSchemaRegistryClient(new MockSchemaRegistryClient, schemaRegistryClientRetries = 0, schemaRegistryClientRetriesDelay = 1.milliseconds) } def test[F[_] : Sync : Logger : Sleep](mockedClient: SchemaRegistryClient, schemaRegistryClientRetries: Int = 3, schemaRegistryClientRetriesDelay: FiniteDuration = 500.milliseconds): F[SchemaRegistry[F]] = Sync[F].delay { - getFromSchemaRegistryClient(mockedClient, schemaRegistryClientRetries, schemaRegistryClientRetriesDelay, useExponentialBackoff = false) + getFromSchemaRegistryClient(mockedClient, schemaRegistryClientRetries, schemaRegistryClientRetriesDelay) } // scalastyle:off method.length private def getFromSchemaRegistryClient[F[_] : Sync : Logger : Sleep](schemaRegistryClient: SchemaRegistryClient, schemaRegistryClientRetries: Int, schemaRegistryClientRetriesDelay: FiniteDuration, - useExponentialBackoff: Boolean): SchemaRegistry[F] = + useExponentialBackoff: Boolean = false): SchemaRegistry[F] = new SchemaRegistry[F] { val retryPolicy = if (useExponentialBackoff) { limitRetries(schemaRegistryClientRetries) |+| exponentialBackoff[F](schemaRegistryClientRetriesDelay)