Lower sensitivity of cats-effect responsiveness warning (close #1309)

snowplow · Aug 7, 2023 · f2c536f · f2c536f
1 parent d29ce80
commit f2c536f
Show file tree

Hide file tree

Showing 6 changed files with 31 additions and 5 deletions.
diff --git a/...abricks-loader/src/main/scala/com/snowplowanalytics/snowplow/loader/databricks/Main.scala b/...abricks-loader/src/main/scala/com/snowplowanalytics/snowplow/loader/databricks/Main.scala
@@ -9,12 +9,16 @@ package com.snowplowanalytics.snowplow.loader.databricks
 
 import cats.effect.{ExitCode, IO, IOApp}
 
-import com.snowplowanalytics.snowplow.scalatracker.emitters.http4s.ceTracking
+import scala.concurrent.duration.DurationInt
 
+import com.snowplowanalytics.snowplow.scalatracker.emitters.http4s.ceTracking
 import com.snowplowanalytics.snowplow.rdbloader.Runner
 
 object Main extends IOApp {
 
+  override def runtimeConfig =
+    super.runtimeConfig.copy(cpuStarvationCheckInterval = 10.seconds)
+
   def run(args: List[String]): IO[ExitCode] =
     Runner.run[IO, Unit](
       args,

diff --git a/.../redshift-loader/src/main/scala/com/snowplowanalytics/snowplow/loader/redshift/Main.scala b/.../redshift-loader/src/main/scala/com/snowplowanalytics/snowplow/loader/redshift/Main.scala
@@ -10,12 +10,16 @@ package com.snowplowanalytics.snowplow.loader.redshift
 import cats.effect.{ExitCode, IO, IOApp}
 import cats.effect.implicits._
 
-import com.snowplowanalytics.snowplow.scalatracker.emitters.http4s.ceTracking
+import scala.concurrent.duration.DurationInt
 
+import com.snowplowanalytics.snowplow.scalatracker.emitters.http4s.ceTracking
 import com.snowplowanalytics.snowplow.rdbloader.Runner
 
 object Main extends IOApp {
 
+  override def runtimeConfig =
+    super.runtimeConfig.copy(cpuStarvationCheckInterval = 10.seconds)
+
   def run(args: List[String]): IO[ExitCode] =
     Runner.run[IO, Unit](
       args,

diff --git a/...nowflake-loader/src/main/scala/com/snowplowanalytics/snowplow/loader/snowflake/Main.scala b/...nowflake-loader/src/main/scala/com/snowplowanalytics/snowplow/loader/snowflake/Main.scala
@@ -10,10 +10,15 @@ package com.snowplowanalytics.snowplow.loader.snowflake
 import cats.effect.{ExitCode, IO, IOApp}
 
 import com.snowplowanalytics.snowplow.scalatracker.emitters.http4s.ceTracking
-
 import com.snowplowanalytics.snowplow.rdbloader.Runner
 
+import scala.concurrent.duration.DurationInt
+
 object Main extends IOApp {
+
+  override def runtimeConfig =
+    super.runtimeConfig.copy(cpuStarvationCheckInterval = 10.seconds)
+
   def run(args: List[String]): IO[ExitCode] =
     Runner.run[IO, Snowflake.InitQueryResult](
       args,

diff --git a/...c/main/scala/com/snowplowanalytics/snowplow/rdbloader/transformer/stream/kafka/Main.scala b/...c/main/scala/com/snowplowanalytics/snowplow/rdbloader/transformer/stream/kafka/Main.scala
@@ -16,8 +16,13 @@ import com.snowplowanalytics.snowplow.rdbloader.transformer.stream.kafka.generat
 import com.snowplowanalytics.snowplow.scalatracker.emitters.http4s.ceTracking
 import org.apache.hadoop.conf.Configuration
 
+import scala.concurrent.duration.DurationInt
+
 object Main extends IOApp {
 
+  override def runtimeConfig =
+    super.runtimeConfig.copy(cpuStarvationCheckInterval = 10.seconds)
+
   def run(args: List[String]): IO[ExitCode] =
     Run.run[IO, KafkaCheckpointer[IO]](
       args,

diff --git a/...main/scala/com/snowplowanalytics/snowplow/rdbloader/transformer/stream/kinesis/Main.scala b/...main/scala/com/snowplowanalytics/snowplow/rdbloader/transformer/stream/kinesis/Main.scala
@@ -14,12 +14,16 @@ import com.snowplowanalytics.snowplow.rdbloader.aws._
 import com.snowplowanalytics.snowplow.rdbloader.common.cloud.{BlobStorage, Queue}
 import com.snowplowanalytics.snowplow.rdbloader.transformer.stream.common.{Config, Run}
 import com.snowplowanalytics.snowplow.rdbloader.transformer.stream.kinesis.generated.BuildInfo
-
 import com.snowplowanalytics.snowplow.scalatracker.emitters.http4s.ceTracking
 
+import scala.concurrent.duration.DurationInt
+
 object Main extends IOApp {
   final val QueueMessageGroupId = "shredding"
 
+  override def runtimeConfig =
+    super.runtimeConfig.copy(cpuStarvationCheckInterval = 10.seconds)
+
   def run(args: List[String]): IO[ExitCode] =
     Run.run[IO, KinesisCheckpointer[IO]](
       args,

diff --git a/.../main/scala/com/snowplowanalytics/snowplow/rdbloader/transformer/stream/pubsub/Main.scala b/.../main/scala/com/snowplowanalytics/snowplow/rdbloader/transformer/stream/pubsub/Main.scala
@@ -23,11 +23,15 @@ import com.snowplowanalytics.snowplow.rdbloader.gcp.{GCS, Pubsub}
 import com.snowplowanalytics.snowplow.rdbloader.transformer.stream.common.Config
 import com.snowplowanalytics.snowplow.rdbloader.transformer.stream.pubsub.generated.BuildInfo
 import com.snowplowanalytics.snowplow.rdbloader.transformer.stream.common.Run
-
 import com.snowplowanalytics.snowplow.scalatracker.emitters.http4s.ceTracking
 
+import scala.concurrent.duration.DurationInt
+
 object Main extends IOApp {
 
+  override def runtimeConfig =
+    super.runtimeConfig.copy(cpuStarvationCheckInterval = 10.seconds)
+
   implicit private def logger[F[_]: Sync]: Logger[F] = Slf4jLogger.getLogger[F]
 
   def run(args: List[String]): IO[ExitCode] =