Fix imports

Author: IgorChvyrov-sm

src/conductor/asyncio_client/automator/task_handler.py

@@ -11,7 +11,7 @@
 from conductor.asyncio_client.automator.task_runner import AsyncTaskRunner
 from conductor.asyncio_client.configuration.configuration import Configuration
 from conductor.asyncio_client.telemetry.metrics_collector import \
-    MetricsCollector
+    AsyncMetricsCollector
 from conductor.asyncio_client.worker.worker import Worker
 from conductor.asyncio_client.worker.worker_interface import WorkerInterface
 from conductor.shared.configuration.settings.metrics_settings import \
@@ -135,7 +135,7 @@ def __create_metrics_provider_process(
             return
         self.metrics_provider_process = Process(
             target=self.coroutine_as_process_target,
-            args=(MetricsCollector.provide_metrics, metrics_settings),
+            args=(AsyncMetricsCollector.provide_metrics, metrics_settings),
         )
         logger.info("Created MetricsProvider process")
 

src/conductor/asyncio_client/automator/task_runner.py

@@ -18,7 +18,7 @@
 from conductor.asyncio_client.http.api_client import ApiClient
 from conductor.asyncio_client.http.exceptions import UnauthorizedException
 from conductor.asyncio_client.telemetry.metrics_collector import \
-    MetricsCollector
+    AsyncMetricsCollector
 from conductor.asyncio_client.worker.worker_interface import WorkerInterface
 from conductor.shared.configuration.settings.metrics_settings import \
     MetricsSettings
@@ -42,7 +42,7 @@ def __init__(
         self.configuration = configuration
         self.metrics_collector = None
         if metrics_settings is not None:
-            self.metrics_collector = MetricsCollector(metrics_settings)
+            self.metrics_collector = AsyncMetricsCollector(metrics_settings)
         self.task_client = TaskResourceApiAdapter(ApiClient(configuration=self.configuration))
 
     async def run(self) -> None: