From 9ea7a0d3ac91503d7318567422763acf705bf8f3 Mon Sep 17 00:00:00 2001 From: Brage Date: Sat, 29 Jul 2023 01:08:55 +0200 Subject: [PATCH] Update --- CommonCode/build.gradle.kts | 2 +- Convert/build.gradle.kts | 2 +- Encode/build.gradle.kts | 2 +- Reader/build.gradle.kts | 2 +- pyMetadata/app.py | 2 ++ 5 files changed, 6 insertions(+), 4 deletions(-) diff --git a/CommonCode/build.gradle.kts b/CommonCode/build.gradle.kts index e86f2f1c..3a68791f 100644 --- a/CommonCode/build.gradle.kts +++ b/CommonCode/build.gradle.kts @@ -20,7 +20,7 @@ dependencies { implementation("com.github.pgreze:kotlin-process:1.3.1") implementation("io.github.microutils:kotlin-logging-jvm:2.0.11") - implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha76") + implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha77") implementation("no.iktdev:exfl:0.0.12-SNAPSHOT") implementation("com.google.code.gson:gson:2.8.9") diff --git a/Convert/build.gradle.kts b/Convert/build.gradle.kts index ff2c72d1..1ead8a87 100644 --- a/Convert/build.gradle.kts +++ b/Convert/build.gradle.kts @@ -25,7 +25,7 @@ dependencies { implementation("no.iktdev.library:subtitle:1.7-SNAPSHOT") - implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha76") + implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha77") implementation("no.iktdev:exfl:0.0.12-SNAPSHOT") implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.7.1") diff --git a/Encode/build.gradle.kts b/Encode/build.gradle.kts index f42cc660..17511a6a 100644 --- a/Encode/build.gradle.kts +++ b/Encode/build.gradle.kts @@ -23,7 +23,7 @@ repositories { dependencies { implementation(project(":CommonCode")) - implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha76") + implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha77") implementation("no.iktdev:exfl:0.0.12-SNAPSHOT") implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.7.1") diff --git a/Reader/build.gradle.kts b/Reader/build.gradle.kts index aab588ca..eac9def1 100644 --- a/Reader/build.gradle.kts +++ b/Reader/build.gradle.kts @@ -24,7 +24,7 @@ repositories { val exposedVersion = "0.38.2" dependencies { - implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha76") + implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha77") implementation("no.iktdev:exfl:0.0.12-SNAPSHOT") implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha14") diff --git a/pyMetadata/app.py b/pyMetadata/app.py index f78ad25e..8c502486 100644 --- a/pyMetadata/app.py +++ b/pyMetadata/app.py @@ -148,6 +148,7 @@ class MessageHandlerThread(threading.Thread): producer.close() def get_metadata(self, name: str) -> Optional[DataResult]: + result = None logger.info("Checking cache for offloading") cache_result = ResultCache.get(name) if cache_result: @@ -160,6 +161,7 @@ class MessageHandlerThread(threading.Thread): if (result.statusType == "SUCCESS"): logger.info("Storing response for %s in in-memory cache", name) ResultCache.add(name, result) + return result def perform_action(self, title) -> DataResult: