Explicit implicit types

core/src/main/scala/org/broadinstitute/dsde/rawls/billing/BillingProfileManagerDAO.scala

@@ -8,14 +8,8 @@ import org.broadinstitute.dsde.rawls.RawlsExceptionWithErrorReport
 import org.broadinstitute.dsde.rawls.billing.BillingProfileManagerDAO.ProfilePolicy.ProfilePolicy
 import org.broadinstitute.dsde.rawls.config.MultiCloudWorkspaceConfig
 import org.broadinstitute.dsde.rawls.model.ProjectRoles.ProjectRole
-import org.broadinstitute.dsde.rawls.model.{
-  AzureManagedAppCoordinates,
-  ErrorReport,
-  ProjectRoles,
-  RawlsBillingAccountName,
-  RawlsRequestContext
-}
-import spray.json.DefaultJsonProtocol
+import org.broadinstitute.dsde.rawls.model.{AzureManagedAppCoordinates, ErrorReport, ProjectRoles, RawlsBillingAccountName, RawlsRequestContext}
+import spray.json.{DefaultJsonProtocol, RootJsonFormat}
 
 import java.util.{Date, UUID}
 import scala.annotation.tailrec
@@ -26,7 +20,7 @@ import scala.util.{Failure, Success, Try}
 case class BpmAzureReportErrorMessage(message: String, statusCode: Int)
 
 object BpmAzureReportErrorMessageJsonProtocol extends DefaultJsonProtocol {
-  implicit val bpmAzureReportErrorMessageFormat = jsonFormat2(BpmAzureReportErrorMessage.apply)
+  implicit val bpmAzureReportErrorMessageFormat: RootJsonFormat[BpmAzureReportErrorMessage] = jsonFormat2(BpmAzureReportErrorMessage.apply)
 }
 
 import spray.json._

core/src/main/scala/org/broadinstitute/dsde/rawls/billing/BillingProjectOrchestrator.scala

@@ -57,7 +57,7 @@ class BillingProjectOrchestrator(ctx: RawlsRequestContext,
     extends StringValidationUtils
     with UserUtils
     with LazyLogging {
-  implicit val errorReportSource = ErrorReportSource("rawls")
+  implicit val errorReportSource: ErrorReportSource = ErrorReportSource("rawls")
 
   /**
    * Creates a "v2" billing project, using either Azure managed app coordinates or a Google Billing Account

core/src/main/scala/org/broadinstitute/dsde/rawls/dataaccess/GoogleBigQueryServiceFactory.scala

@@ -7,6 +7,7 @@ import org.apache.commons.io.IOUtils
 import org.broadinstitute.dsde.rawls.model.GoogleProjectId
 import org.broadinstitute.dsde.workbench.google2.GoogleBigQueryService
 import org.broadinstitute.dsde.workbench.model.google.GoogleProject
+import org.typelevel.log4cats.SelfAwareStructuredLogger
 import org.typelevel.log4cats.slf4j.Slf4jLogger
 
 import java.io.ByteArrayInputStream
@@ -23,8 +24,8 @@ import scala.concurrent.ExecutionContext
  */
 class GoogleBigQueryServiceFactory(pathToCredentialJson: String)(implicit executionContext: ExecutionContext) {
 
-  implicit lazy val logger = Slf4jLogger.getLogger[IO]
-  implicit lazy val timer = Temporal[IO]
+  implicit lazy val logger: SelfAwareStructuredLogger[IO] = Slf4jLogger.getLogger[IO]
+  implicit lazy val timer: Temporal[IO] = Temporal[IO]
 
   def getServiceForPet(petKey: String,
                        projectId: GoogleProject

core/src/main/scala/org/broadinstitute/dsde/rawls/dataaccess/HttpBondApiDAO.scala

@@ -10,6 +10,7 @@ import org.broadinstitute.dsde.rawls.RawlsExceptionWithErrorReport
 import org.broadinstitute.dsde.rawls.dataaccess.BondJsonSupport._
 import org.broadinstitute.dsde.rawls.model.UserInfo
 import org.broadinstitute.dsde.rawls.util.{HttpClientUtilsStandard, Retry}
+import spray.json.RootJsonFormat
 
 import scala.concurrent.{ExecutionContext, Future}
 
@@ -21,10 +22,10 @@ case class Providers(providers: List[String])
 object BondJsonSupport {
   import spray.json.DefaultJsonProtocol._
 
-  implicit val BondServiceAccountEmailFormat = jsonFormat1(BondServiceAccountEmail)
-  implicit val BondResponseDataFormat = jsonFormat1(BondResponseData)
+  implicit val BondServiceAccountEmailFormat: RootJsonFormat[BondServiceAccountEmail] = jsonFormat1(BondServiceAccountEmail)
+  implicit val BondResponseDataFormat: RootJsonFormat[BondResponseData] = jsonFormat1(BondResponseData)
 
-  implicit val providersFormat = jsonFormat1(Providers)
+  implicit val providersFormat: RootJsonFormat[Providers] = jsonFormat1(Providers)
 
 }
 

core/src/main/scala/org/broadinstitute/dsde/rawls/dataaccess/HttpExecutionServiceDAO.scala

@@ -1,7 +1,7 @@
 package org.broadinstitute.dsde.rawls.dataaccess
 
 import akka.actor.ActorSystem
-import akka.http.scaladsl.Http
+import akka.http.scaladsl.{Http, HttpExt}
 import akka.http.scaladsl.client.RequestBuilding._
 import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport._
 import akka.http.scaladsl.marshalling.Marshal
@@ -16,7 +16,7 @@ import org.broadinstitute.dsde.rawls.metrics.{Expansion, InstrumentedRetry, Rawl
 import org.broadinstitute.dsde.rawls.model.ExecutionJsonSupport._
 import org.broadinstitute.dsde.rawls.model.StatusJsonSupport._
 import org.broadinstitute.dsde.rawls.model._
-import org.broadinstitute.dsde.rawls.util.{FutureSupport, HttpClientUtilsGzipInstrumented}
+import org.broadinstitute.dsde.rawls.util.{FutureSupport, HttpClientUtils, HttpClientUtilsGzipInstrumented}
 import spray.json.DefaultJsonProtocol._
 import spray.json._
 
@@ -38,11 +38,11 @@ class HttpExecutionServiceDAO(executionServiceURL: String, override val workbenc
     with LazyLogging
     with RawlsInstrumented {
 
-  implicit private lazy val baseMetricBuilder =
+  implicit private lazy val baseMetricBuilder: ExpandedMetricBuilder =
     ExpandedMetricBuilder.expand(SubsystemMetricKey, Subsystems.Cromwell)
 
-  override val http = Http(system)
-  override val httpClientUtils = HttpClientUtilsGzipInstrumented()
+  override val http: HttpExt = Http(system)
+  override val httpClientUtils: HttpClientUtils = HttpClientUtilsGzipInstrumented()
 
   // Strip out workflow IDs from metrics by providing a redactedUriExpansion
   override protected val UriExpansion: Expansion[Uri] = RawlsExpansion.redactedUriExpansion(

core/src/main/scala/org/broadinstitute/dsde/rawls/dataaccess/HttpGoogleServicesDAO.scala

@@ -18,12 +18,7 @@ import com.google.api.client.googleapis.json.GoogleJsonResponseException
 import com.google.api.client.http.{HttpRequest, HttpRequestInitializer, HttpResponseException, InputStreamContent}
 import com.google.api.client.json.gson.GsonFactory
 import com.google.api.services.cloudbilling.Cloudbilling
-import com.google.api.services.cloudbilling.model.{
-  BillingAccount,
-  ListBillingAccountsResponse,
-  ProjectBillingInfo,
-  TestIamPermissionsRequest
-}
+import com.google.api.services.cloudbilling.model.{BillingAccount, ListBillingAccountsResponse, ProjectBillingInfo, TestIamPermissionsRequest}
 import com.google.api.services.cloudresourcemanager.CloudResourceManager
 import com.google.api.services.cloudresourcemanager.model._
 import com.google.api.services.compute.{Compute, ComputeScopes}
@@ -61,6 +56,7 @@ import org.broadinstitute.dsde.workbench.google2.util.RetryPredicates
 import org.broadinstitute.dsde.workbench.model.google.{GcsBucketName, GoogleProject, GoogleResourceTypes, IamPermission}
 import org.broadinstitute.dsde.workbench.model.{TraceId, WorkbenchEmail}
 import org.joda.time.DateTime
+import org.typelevel.log4cats.SelfAwareStructuredLogger
 import org.typelevel.log4cats.slf4j.Slf4jLogger
 import spray.json._
 
@@ -101,7 +97,7 @@ class HttpGoogleServicesDAO(val clientSecrets: GoogleClientSecrets,
     with GoogleUtilities {
   val http = Http(system)
   val httpClientUtils = HttpClientUtilsStandard()
-  implicit val log4CatsLogger = Slf4jLogger.getLogger[IO]
+  implicit val log4CatsLogger: SelfAwareStructuredLogger[IO] = Slf4jLogger.getLogger[IO]
 
   val groupMemberRole =
     "MEMBER" // the Google Group role corresponding to a member (note that this is distinct from the GCS roles defined in WorkspaceAccessLevel)

core/src/main/scala/org/broadinstitute/dsde/rawls/dataaccess/HttpImportServiceDAO.scala

@@ -10,14 +10,15 @@ import org.broadinstitute.dsde.rawls.RawlsExceptionWithErrorReport
 import org.broadinstitute.dsde.rawls.model.ImportStatuses.ImportStatus
 import org.broadinstitute.dsde.rawls.model.{ImportStatuses, UserInfo, WorkspaceName}
 import org.broadinstitute.dsde.rawls.util.{HttpClientUtilsStandard, Retry}
+import spray.json.RootJsonFormat
 
 import java.util.UUID
 import scala.concurrent.{ExecutionContext, Future}
 
 object ImportServiceJsonSupport {
   import spray.json.DefaultJsonProtocol._
 
-  implicit val importServiceResponseFormat = jsonFormat2(ImportServiceResponse)
+  implicit val importServiceResponseFormat: RootJsonFormat[ImportServiceResponse] = jsonFormat2(ImportServiceResponse)
 }
 
 class HttpImportServiceDAO(url: String)(implicit

core/src/main/scala/org/broadinstitute/dsde/rawls/dataaccess/slick/DriverComponent.scala

@@ -16,7 +16,7 @@ trait DriverComponent extends StringValidationUtils {
   val batchSize: Int // used for writes to group inserts/updates; must be explicitly utilized via custom business logic
   val fetchSize: Int // used during Slick streaming to set the size of pages; must be explicitly set via withStatementParameters
   implicit val executionContext: ExecutionContext
-  implicit override val errorReportSource = ErrorReportSource("rawls")
+  implicit override val errorReportSource: ErrorReportSource = ErrorReportSource("rawls")
 
   // needed by MySQL but not actually used; we will always overwrite
   val defaultTimeStamp = Timestamp.valueOf("2001-01-01 01:01:01.0")
@@ -108,8 +108,8 @@ trait RawSqlQuery {
 
   import driver.api._
 
-  implicit val GetUUIDResult = GetResult(r => uuidColumnType.fromBytes(r.nextBytes()))
-  implicit val GetUUIDOptionResult = GetResult(r => Option(uuidColumnType.fromBytes(r.nextBytes())))
+  implicit val GetUUIDResult: GetResult[UUID] = GetResult(r => uuidColumnType.fromBytes(r.nextBytes()))
+  implicit val GetUUIDOptionResult: GetResult[Option[UUID]] = GetResult(r => Option(uuidColumnType.fromBytes(r.nextBytes())))
   implicit object SetUUIDParameter extends SetParameter[UUID] {
     def apply(v: UUID, pp: PositionedParameters) { pp.setBytes(uuidColumnType.toBytes(v)) }
   }

core/src/main/scala/org/broadinstitute/dsde/rawls/dataaccess/slick/EntityComponent.scala

@@ -237,7 +237,7 @@ trait EntityComponent {
     // noinspection SqlDialectInspection,DuplicatedCode
     private object EntityRecordRawSqlQuery extends RawSqlQuery {
       val driver: JdbcProfile = EntityComponent.this.driver
-      implicit val getEntityRecord = GetResult(r => EntityRecord(r.<<, r.<<, r.<<, r.<<, r.<<, r.<<, r.<<))
+      implicit val getEntityRecord: GetResult[EntityRecord] = GetResult(r => EntityRecord(r.<<, r.<<, r.<<, r.<<, r.<<, r.<<, r.<<))
 
       def action(workspaceId: UUID, entities: Set[AttributeEntityReference]): ReadAction[Seq[EntityRecord]] =
         if (entities.isEmpty) {
@@ -317,7 +317,7 @@ trait EntityComponent {
       val driver: JdbcProfile = EntityComponent.this.driver
 
       // tells slick how to convert a result row from a raw sql query to an instance of EntityAndAttributesResult
-      implicit val getEntityAndAttributesResult = GetResult { r =>
+      implicit val getEntityAndAttributesResult: GetResult[EntityAndAttributesResult] = GetResult { r =>
         // note that the number and order of all the r.<< match precisely with the select clause of baseEntityAndAttributeSql
         val entityRec = EntityRecord(r.<<, r.<<, r.<<, r.<<, r.<<, r.<<, r.<<)
 

core/src/main/scala/org/broadinstitute/dsde/rawls/dataaccess/slick/RawlsBillingProjectComponent.scala

@@ -11,6 +11,8 @@ import org.broadinstitute.dsde.rawls.monitor.migration.MigrationUtils
 import org.broadinstitute.dsde.rawls.monitor.migration.MigrationUtils.Implicits.InsertExtensionMethod
 import org.broadinstitute.dsde.rawls.monitor.migration.MigrationUtils.Outcome
 import org.broadinstitute.dsde.workbench.model.google.{BigQueryDatasetName, BigQueryTableName, GoogleProject}
+import slick.ast.BaseTypedType
+import slick.jdbc.JdbcType
 
 import java.sql.Timestamp
 import java.time.Instant
@@ -189,12 +191,12 @@ trait RawlsBillingProjectComponent {
 
   // these 2 implicits are lazy because there is a timing problem initializing MappedColumnType, if they are not lazy
   // we get null pointer exceptions
-  implicit lazy val googleApiTypeColumnType = MappedColumnType.base[GoogleApiType, String](
+  implicit lazy val googleApiTypeColumnType: JdbcType[GoogleApiType] with BaseTypedType[GoogleApiType] = MappedColumnType.base[GoogleApiType, String](
     apiType => apiType.toString,
     stringValue => GoogleApiTypes.withName(stringValue)
   )
 
-  implicit lazy val googleOperationNameColumnType = MappedColumnType.base[GoogleOperationName, String](
+  implicit lazy val googleOperationNameColumnType: JdbcType[GoogleOperationName] with BaseTypedType[GoogleOperationName] = MappedColumnType.base[GoogleOperationName, String](
     operationName => operationName.toString,
     stringValue => GoogleOperationNames.withName(stringValue)
   )

core/src/main/scala/org/broadinstitute/dsde/rawls/dataaccess/slick/SubmissionComponent.scala

@@ -563,7 +563,7 @@ trait SubmissionComponent {
                                             externalEntity: Option[AttributeEntityReference]
       )
 
-      implicit val getWorkflowMessagesListResult = GetResult { r =>
+      implicit val getWorkflowMessagesListResult: GetResult[WorkflowMessagesListResult] = GetResult { r =>
         val workflowRec = WorkflowRecord(r.<<, r.<<, r.<<, r.<<, r.<<, r.<<, r.<<, r.<<, r.<<)
         val rootEntityTypeOption: Option[String] = r.<<
 
@@ -602,7 +602,7 @@ trait SubmissionComponent {
                                                    submissionAttributeRec: Option[SubmissionAttributeRecord]
       )
 
-      implicit val getWorkflowInputResolutionListResult = GetResult { r =>
+      implicit val getWorkflowInputResolutionListResult: GetResult[WorkflowInputResolutionListResult] = GetResult { r =>
         val workflowRec = WorkflowRecord(r.<<, r.<<, r.<<, r.<<, r.<<, r.<<, r.<<, r.<<, r.<<)
         val (submissionValidation, attribute) = r.nextLongOption() match {
           case Some(submissionValidationId) =>
@@ -685,7 +685,7 @@ trait SubmissionComponent {
     object GatherStatusesForWorkspaceSubmissionsQuery extends RawSqlQuery {
       val driver: JdbcProfile = SubmissionComponent.this.driver
 
-      implicit val getSubmissionWorkflowStatusResponse = GetResult { r =>
+      implicit val getSubmissionWorkflowStatusResponse: GetResult[SubmissionWorkflowStatusResponse] = GetResult { r =>
         SubmissionWorkflowStatusResponse(r.<<, r.<<, r.<<, r.<<)
       }
 

core/src/main/scala/org/broadinstitute/dsde/rawls/metrics/RawlsExpansion.scala

@@ -30,7 +30,7 @@ object RawlsExpansion {
     * This takes an upper type bound {{{A <: RawlsEnumeration}}} so it can work with any
     * subtype of RawlsEnumeration.
     */
-  implicit def RawlsEnumerationExpansion[A <: RawlsEnumeration[_]] = new Expansion[A] {}
+  implicit def RawlsEnumerationExpansion[A <: RawlsEnumeration[_]]: Expansion[A] = new Expansion[A] {}
 
   /**
     * Creates an expansion for Uri which redacts pieces of the Uri matched by the provided PathMatcher.

core/src/main/scala/org/broadinstitute/dsde/rawls/model/MethodRepoModel.scala

@@ -49,7 +49,7 @@ class MethodRepoJsonSupport extends JsonSupport {
     }
   }
 
-  implicit val AgoraEntityFormat = jsonFormat10(AgoraEntity)
+  implicit val AgoraEntityFormat: RootJsonFormat[AgoraEntity] = jsonFormat10(AgoraEntity)
 
 }
 

core/src/main/scala/org/broadinstitute/dsde/rawls/model/SamModel.scala

@@ -3,6 +3,7 @@ package org.broadinstitute.dsde.rawls.model
 import org.broadinstitute.dsde.workbench.model.WorkbenchIdentityJsonSupport._
 import org.broadinstitute.dsde.workbench.model._
 import spray.json.DefaultJsonProtocol._
+import spray.json.RootJsonFormat
 
 /*
   Resource type names
@@ -169,22 +170,22 @@ case class SamUserResource(resourceId: String,
 case class SamUserStatusResponse(userSubjectId: String, userEmail: String, enabled: Boolean)
 
 object SamModelJsonSupport extends JsonSupport {
-  implicit val SamFullyQualifiesResourceIdFormat = jsonFormat2(SamFullyQualifiedResourceId)
-  implicit val SamResourcePolicyNameFormat = ValueObjectFormat(SamResourcePolicyName)
-  implicit val SamResourceActionFormat = ValueObjectFormat(SamResourceAction)
-  implicit val SamResourceRoleFormat = ValueObjectFormat(SamResourceRole)
-
-  implicit val SamPolicyFormat = jsonFormat3(SamPolicy)
-  implicit val SamPolicyWithNameAndEmailFormat = jsonFormat3(SamPolicyWithNameAndEmail)
-  implicit val SamResourceWithPoliciesFormat = jsonFormat5(SamResourceWithPolicies)
-  implicit val SamResourceIdWithPolicyNameFormat = jsonFormat5(SamResourceIdWithPolicyName)
-  implicit val SamPolicySyncStatusFormat = jsonFormat2(SamPolicySyncStatus)
-
-  implicit val SamCreateResourceAccessPolicyIdResponseFormat = jsonFormat2(SamCreateResourceAccessPolicyIdResponse)
-  implicit val samCreateResourcePolicyResponseFormat = jsonFormat2(SamCreateResourcePolicyResponse)
-  implicit val SamCreateResourceResponseFormat = jsonFormat4(SamCreateResourceResponse)
-
-  implicit val SamRolesAndActionsFormat = jsonFormat2(SamRolesAndActions)
-  implicit val SamUserResourceFormat = jsonFormat6(SamUserResource)
-  implicit val SamUserStatusResponseFormat = jsonFormat3(SamUserStatusResponse)
+  implicit val SamFullyQualifiesResourceIdFormat: RootJsonFormat[SamFullyQualifiedResourceId] = jsonFormat2(SamFullyQualifiedResourceId)
+  implicit val SamResourcePolicyNameFormat: ValueObjectFormat[SamResourcePolicyName] = ValueObjectFormat(SamResourcePolicyName)
+  implicit val SamResourceActionFormat: ValueObjectFormat[SamResourceAction] = ValueObjectFormat(SamResourceAction)
+  implicit val SamResourceRoleFormat: ValueObjectFormat[SamResourceRole] = ValueObjectFormat(SamResourceRole)
+
+  implicit val SamPolicyFormat: RootJsonFormat[SamPolicy] = jsonFormat3(SamPolicy)
+  implicit val SamPolicyWithNameAndEmailFormat: RootJsonFormat[SamPolicyWithNameAndEmail] = jsonFormat3(SamPolicyWithNameAndEmail)
+  implicit val SamResourceWithPoliciesFormat: RootJsonFormat[SamResourceWithPolicies] = jsonFormat5(SamResourceWithPolicies)
+  implicit val SamResourceIdWithPolicyNameFormat: RootJsonFormat[SamResourceIdWithPolicyName] = jsonFormat5(SamResourceIdWithPolicyName)
+  implicit val SamPolicySyncStatusFormat: RootJsonFormat[SamPolicySyncStatus] = jsonFormat2(SamPolicySyncStatus)
+
+  implicit val SamCreateResourceAccessPolicyIdResponseFormat: RootJsonFormat[SamCreateResourceAccessPolicyIdResponse] = jsonFormat2(SamCreateResourceAccessPolicyIdResponse)
+  implicit val samCreateResourcePolicyResponseFormat: RootJsonFormat[SamCreateResourcePolicyResponse] = jsonFormat2(SamCreateResourcePolicyResponse)
+  implicit val SamCreateResourceResponseFormat: RootJsonFormat[SamCreateResourceResponse] = jsonFormat4(SamCreateResourceResponse)
+
+  implicit val SamRolesAndActionsFormat: RootJsonFormat[SamRolesAndActions] = jsonFormat2(SamRolesAndActions)
+  implicit val SamUserResourceFormat: RootJsonFormat[SamUserResource] = jsonFormat6(SamUserResource)
+  implicit val SamUserStatusResponseFormat: RootJsonFormat[SamUserStatusResponse] = jsonFormat3(SamUserStatusResponse)
 }

core/src/main/scala/org/broadinstitute/dsde/rawls/model/SpendReportingModel.scala

@@ -192,9 +192,9 @@ class SpendReportingJsonSupport extends JsonSupport {
     }
   }
 
-  implicit val SpendReportingAggregationKeyParameterFormat = jsonFormat2(SpendReportingAggregationKeyWithSub)
+  implicit val SpendReportingAggregationKeyParameterFormat: RootJsonFormat[SpendReportingAggregationKeyWithSub] = jsonFormat2(SpendReportingAggregationKeyWithSub)
 
-  implicit val BillingProjectSpendConfigurationFormat = jsonFormat2(BillingProjectSpendConfiguration)
+  implicit val BillingProjectSpendConfigurationFormat: RootJsonFormat[BillingProjectSpendConfiguration] = jsonFormat2(BillingProjectSpendConfiguration)
 
   implicit val SpendReportingAggregationFormat: JsonFormat[SpendReportingAggregation] = lazyFormat(
     jsonFormat2(SpendReportingAggregation.apply)

core/src/main/scala/org/broadinstitute/dsde/rawls/model/UserModel.scala

@@ -1,5 +1,7 @@
 package org.broadinstitute.dsde.rawls.model
 
+import spray.json.RootJsonFormat
+
 /**
  * Created by dvoet on 10/27/15.
  */
@@ -10,8 +12,8 @@ case class UserList(userList: Seq[String])
 class UserJsonSupport extends JsonSupport {
   import spray.json.DefaultJsonProtocol._
 
-  implicit val UserIdInfoFormat = jsonFormat3(UserIdInfo)
-  implicit val UserListFormat = jsonFormat1(UserList)
+  implicit val UserIdInfoFormat: RootJsonFormat[UserIdInfo] = jsonFormat3(UserIdInfo)
+  implicit val UserListFormat: RootJsonFormat[UserList] = jsonFormat1(UserList)
 }
 
 object UserJsonSupport extends UserJsonSupport

core/src/main/scala/org/broadinstitute/dsde/rawls/model/package.scala

@@ -1,5 +1,5 @@
 package org.broadinstitute.dsde.rawls
 
 package object model {
-  implicit val errorReportSource = ErrorReportSource("rawls")
+  implicit val errorReportSource: ErrorReportSource = ErrorReportSource("rawls")
 }

core/src/main/scala/org/broadinstitute/dsde/rawls/monitor/AvroUpsertMonitor.scala

@@ -87,7 +87,7 @@ object AvroUpsertMonitorSupervisor {
     )
 
   import spray.json.DefaultJsonProtocol._
-  implicit val updateImportStatusFormat = jsonFormat5(UpdateImportStatus)
+  implicit val updateImportStatusFormat: RootJsonFormat[UpdateImportStatus] = jsonFormat5(UpdateImportStatus)
 }
 
 case class UpdateImportStatus(importId: String,
@@ -227,7 +227,7 @@ class AvroUpsertMonitorActor(val pollInterval: FiniteDuration,
                               jobId: String,
                               startTime: String
   )
-  implicit val avroMetadataJsonFormat = jsonFormat6(AvroMetadataJson)
+  implicit val avroMetadataJsonFormat: RootJsonFormat[AvroMetadataJson] = jsonFormat6(AvroMetadataJson)
 
   self ! StartMonitorPass