python3.9

celeryconfig.py

-CELERY_RESULT_BACKEND = 'amqp://'
-CELERY_TASK_RESULT_EXPIRES = 300
-CELERY_ENABLE_UTC = True
-CELERY_ACCEPT_CONTENT = ['json', 'pickle', 'msgpack', 'yaml']
-CELERY_TASK_SERIALIZER = 'json'
-CELERY_RESULT_SERIALIZER = 'json'
+result_backend = 'amqp://'
+task_result_expires = 300
+result_expires = 300
+timezone = 'utc'
+enable_utc = True
+accept_content = ['json', 'pickle_v2']
+task_serializer = 'json'
+result_serializer = 'pickle_v2'
+task_store_errors_even_if_ignored = True
 

netcelery.py

 """ Celery module for libvirt RPC calls. """
 from celery import Celery
+import serializers
 from kombu import Queue, Exchange
 from os import getenv
 

requirements/base.txt

-setuptools<58
-amqp==1.4.9
-billiard==3.3.0.23
-celery==3.1.18
-decorator==3.4.0
-future==0.18.2
-GitPython==3.1.18
-importlib-metadata==4.8.3
-kombu==3.0.30
-lxml==3.4.2
-libvirt-python==7.10.0
-pillow==8.4.0
-psutil==4.4.2
-pytz==2021.3
-smmap==5.0.0
-typing_extensions==4.0.1
-vine==5.0.0
-zipp==3.6.0
+# build tooling
+setuptools>=58,<70
+wheel
+
+# Celery 4 ökoszisztéma (egymással kompatibilis verziók)
+celery==4.4.7
+kombu==4.6.11
+amqp==2.6.1
+billiard==3.6.4.0
+vine==1.3.0
+pytz>=2021.3,<2025.0
+
+# a többi csomag modernizálva, de kompatibilitásra figyelve
+decorator>=4.4.2,<5.2
+future>=0.18.3
+GitPython>=3.1.18,<3.2
+smmap>=5.0.0,<6.0
+lxml>=4.9.3,<5.0
+libvirt-python==10.0.0
+pillow>=8.4.0,<10.0
+psutil>=5.9.0,<6.0
+typing-extensions>=4.0.1,<5.0
+
+# csak régebbi Pythonnál szükségesek — 3.9-en általában elhagyhatók,
+# de ha kódban importáljátok, maradhatnak így, markerrel:
+importlib-metadata>=4.8.3,<5.0 ; python_version < "3.10"
+zipp>=3.6.0,<4.0 ; python_version < "3.10"
+
+# tesztkeret, ha még használjátok
 nose==1.3.7

requirements/install_first.txt

-setuptools<58
-pip<21
+setuptools>=58,<70
+pip<24
 

serializers.py

+# serializers.py  
+from kombu.serialization import register
+import pickle
+
+def pickle_v2_dumps(obj):
+    return pickle.dumps(obj, protocol=2)
+
+def pickle_v2_loads(s):
+    return pickle.loads(s)
+
+register(
+    'pickle_v2',
+    pickle_v2_dumps,
+    pickle_v2_loads,
+    content_type='application/x-pickle',
+    content_encoding='binary',
+)
+

vmcelery.py

 """ Celery module for libvirt RPC calls. """
 
 from celery import Celery
+import serializers
 from kombu import Queue, Exchange
 from os import getenv