Skip to content

Commit 840aefb

Browse files
committed
multiprocessing stopped
1 parent aeade6e commit 840aefb

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

RedisScheduler/RedisScheduler.py

+3-2
Original file line numberDiff line numberDiff line change
@@ -126,8 +126,9 @@ def start_listening(self, subscribe_channel='__keyevent@0__:expired', handler='s
126126
print(' -- listener initiating -- ')
127127
print(subscribe_channel, handler)
128128
try:
129-
listener_service = multiprocessing.Process(target=self.subscribe_event, args=(subscribe_channel, handler,))
130-
listener_service.start()
129+
# listener_service = multiprocessing.Process(target=self.subscribe_event, args=(subscribe_channel, handler,))
130+
# listener_service.start()
131+
self.subscribe_event(subscribe_channel, handler)
131132
except Exception as e:
132133
print(e)
133134
print(' -- listener initiated -- ')

RedisScheduler/__init__.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
__author__ = 'anistark'
2-
__version__ = '2.1.0'
2+
__version__ = '2.2.0'
33
__title__ = 'RedisScheduler'
44

55
# Importing Classes

0 commit comments

Comments
 (0)