From e00eaf6cb82b3831fb5c5b7aed709e639b9d49a1 Mon Sep 17 00:00:00 2001
From: Akash Kulkarni <113392464+akashkulk@users.noreply.github.com>
Date: Tue, 10 Sep 2024 10:05:46 -0700
Subject: [PATCH] [Source-mysql-v2] : Fix tests to be passing on local (#45363)

---
 .../source/mysql/MysqlSourceDatatypeIntegrationTest.kt        | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/airbyte-integrations/connectors/source-mysql-v2/src/test/kotlin/io/airbyte/integrations/source/mysql/MysqlSourceDatatypeIntegrationTest.kt b/airbyte-integrations/connectors/source-mysql-v2/src/test/kotlin/io/airbyte/integrations/source/mysql/MysqlSourceDatatypeIntegrationTest.kt
index 30a9d520a548..afde5a8dee7d 100644
--- a/airbyte-integrations/connectors/source-mysql-v2/src/test/kotlin/io/airbyte/integrations/source/mysql/MysqlSourceDatatypeIntegrationTest.kt
+++ b/airbyte-integrations/connectors/source-mysql-v2/src/test/kotlin/io/airbyte/integrations/source/mysql/MysqlSourceDatatypeIntegrationTest.kt
@@ -2,7 +2,7 @@
 package io.airbyte.integrations.source.mysql
 
 import com.fasterxml.jackson.databind.JsonNode
-import io.airbyte.cdk.TestClockFactory
+import io.airbyte.cdk.ClockFactory
 import io.airbyte.cdk.command.CliRunner
 import io.airbyte.cdk.data.AirbyteType
 import io.airbyte.cdk.data.LeafAirbyteType
@@ -83,7 +83,7 @@ class MysqlSourceDatatypeIntegrationTest {
         val actualReads: Map<String, BufferingOutputConsumer> by lazy {
             val result: Map<String, BufferingOutputConsumer> =
                 allStreamNamesAndRecordData.keys.associateWith {
-                    BufferingOutputConsumer(TestClockFactory().fixed())
+                    BufferingOutputConsumer(ClockFactory().fixed())
                 }
             for (msg in allReadMessages) {
                 result[streamName(msg) ?: continue]?.accept(msg)