iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update

Browse Source
This commit is contained in:
Brage 2023-07-29 01:08:55 +02:00
parent 79836faa46
commit 9ea7a0d3ac
5 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
CommonCode/build.gradle.kts
View File

@ -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")

2
Convert/build.gradle.kts
View File

@ -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")

2
Encode/build.gradle.kts
View File

@ -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")

2
Reader/build.gradle.kts
View File

@ -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")

2
pyMetadata/app.py
View File

@ -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: