add horizon. to import level

Author: omer9564

horizon/facts/client.py

@@ -8,8 +8,8 @@
 from starlette.requests import Request as FastApiRequest
 from starlette.responses import Response as FastApiResponse, StreamingResponse
 
-from config import sidecar_config
-from startup.remote_config import get_remote_config
+from horizon.config import sidecar_config
+from horizon.startup.remote_config import get_remote_config
 
 
 class FactsClient:

horizon/facts/dependencies.py

@@ -3,8 +3,8 @@
 from fastapi import Depends, Request, HTTPException
 from opal_client import OpalClient
 
-from config import sidecar_config
-from facts.update_subscriber import DataUpdateSubscriber
+from horizon.config import sidecar_config
+from horizon.facts.update_subscriber import DataUpdateSubscriber
 
 
 def get_opal_client(request: Request) -> OpalClient:

horizon/facts/opal_forwarder.py

@@ -5,8 +5,8 @@
 from opal_common.fetcher.providers.http_fetch_provider import HttpFetcherConfig
 from opal_common.schemas.data import DataSourceEntry, DataUpdate
 
-from config import sidecar_config
-from startup.remote_config import get_remote_config
+from horizon.config import sidecar_config
+from horizon.startup.remote_config import get_remote_config
 
 
 @cache

horizon/facts/router.py

@@ -10,11 +10,17 @@
 from loguru import logger
 from opal_common.schemas.data import DataSourceEntry
 
-from authentication import enforce_pdp_token
-from facts.client import FactsClientDependency, FactsClient
-from facts.dependencies import DataUpdateSubscriberDependency, WaitTimeoutDependency
-from facts.opal_forwarder import create_data_source_entry, create_data_update_entry
-from facts.update_subscriber import DataUpdateSubscriber
+from horizon.authentication import enforce_pdp_token
+from horizon.facts.client import FactsClientDependency, FactsClient
+from horizon.facts.dependencies import (
+    DataUpdateSubscriberDependency,
+    WaitTimeoutDependency,
+)
+from horizon.facts.opal_forwarder import (
+    create_data_source_entry,
+    create_data_update_entry,
+)
+from horizon.facts.update_subscriber import DataUpdateSubscriber
 
 facts_router = APIRouter(dependencies=[Depends(enforce_pdp_token)])