From 8746ed0d6fd9a343e3777744623cec662f9d6e04 Mon Sep 17 00:00:00 2001 From: bskjon Date: Tue, 18 Jun 2024 19:04:49 +0200 Subject: [PATCH] Update --- apps/pyMetadata/app.py | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/apps/pyMetadata/app.py b/apps/pyMetadata/app.py index db84ef4a..f63921be 100644 --- a/apps/pyMetadata/app.py +++ b/apps/pyMetadata/app.py @@ -7,19 +7,19 @@ import uuid import threading import json import time -from clazz.shared import ConsumerRecord, MediaEvent, decode_key, decode_value, suppress_ignore, consume_on_key +from .clazz.shared import ConsumerRecord, MediaEvent, decode_key, decode_value, suppress_ignore, consume_on_key from fuzzywuzzy import fuzz -from algo.AdvancedMatcher import AdvancedMatcher -from algo.SimpleMatcher import SimpleMatcher -from algo.PrefixMatcher import PrefixMatcher -from clazz.KafkaMessageSchema import KafkaMessage, MessageDataWrapper -from clazz.Metadata import Metadata +from .algo.AdvancedMatcher import AdvancedMatcher +from .algo.SimpleMatcher import SimpleMatcher +from .algo.PrefixMatcher import PrefixMatcher +from .clazz.KafkaMessageSchema import KafkaMessage, MessageDataWrapper +from .clazz.Metadata import Metadata from kafka import KafkaConsumer, KafkaProducer -from sources.anii import Anii -from sources.imdb import Imdb -from sources.mal import Mal +from .sources.anii import Anii +from .sources.imdb import Imdb +from .sources.mal import Mal # Konfigurer Kafka-forbindelsen bootstrap_servers = os.environ.get("KAFKA_BOOTSTRAP_SERVER") or "127.0.0.1:9092"