diff --git a/CHANGELOG.md b/CHANGELOG.md index 8c61c4291..aa60d8dba 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -12,6 +12,7 @@ ### Fixed - [Storage] Fixed "KeyError: 'monitoring_interval'" error when instantiating Storage() class +- [k8s] Fixed bug between threads when there are multiple executions ## [v3.4.1] diff --git a/lithops/serverless/backends/k8s/entry_point.py b/lithops/serverless/backends/k8s/entry_point.py index a4c6eea63..e3b576f05 100644 --- a/lithops/serverless/backends/k8s/entry_point.py +++ b/lithops/serverless/backends/k8s/entry_point.py @@ -24,8 +24,7 @@ import time import requests from functools import partial -from multiprocessing import Value -from threading import Thread +from multiprocessing import Value, Process from lithops.version import __version__ from lithops.utils import setup_lithops_logger, b64str_to_dict @@ -178,7 +177,7 @@ def callback_work_queue(ch, method, properties, body): with running_jobs.get_lock(): running_jobs.value -= processes_to_start - Thread(target=run_job_k8s_rabbitmq, args=([message])).start() + Process(target=run_job_k8s_rabbitmq, args=(message,)).start() ch.basic_ack(delivery_tag=method.delivery_tag)