Skip to content

Commit aa3bf3b

Browse files
author
Joel Collins
committed
Added task started event
1 parent 01e54c5 commit aa3bf3b

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

labthings/core/tasks/thread.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
from gevent import Greenlet, GreenletExit
22
from gevent.thread import get_ident
3+
from gevent.event import Event
34
import datetime
45
import logging
56
import traceback
@@ -28,6 +29,9 @@ def __init__(self, target=None, args=None, kwargs=None):
2829
# A UUID for the TaskThread (not the same as the threading.Thread ident)
2930
self._ID = uuid.uuid4() # Task ID
3031

32+
# Event to track if the task has started
33+
self.started_event = Event()
34+
3135
# Make _target, _args, and _kwargs available to the subclass
3236
self._target = target
3337
self._args = args
@@ -96,6 +100,7 @@ def wrapped(*args, **kwargs):
96100

97101
self._status = "running"
98102
self._start_time = datetime.datetime.now().strftime("%Y-%m-%d %H-%M-%S")
103+
self.started_event.set()
99104
try:
100105
self._return_value = f(*args, **kwargs)
101106
self._status = "success"

0 commit comments

Comments
 (0)