Skip to content

Commit afb9974

Browse files
committed
Celery dependency
1 parent 2e1ab16 commit afb9974

File tree

3 files changed

+13
-4
lines changed

3 files changed

+13
-4
lines changed

setup.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
from setuptools import setup
22

33
setup(
4-
version="1.0.37",
5-
install_requires=["slackclient"]
4+
version="1.0.38",
5+
install_requires=["slackclient", "celery"]
66
)

slack_app/tasks.py

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
from celery import shared_task
2+
3+
from .signals import slack_event_received
4+
5+
6+
@shared_task
7+
def receive_slack_signal_task(sender, event_type, event_data, **data):
8+
slack_event_received.send(sender=sender, event_type=event_type, event_data=event_data, **data)
9+

slack_app/views.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,7 @@
1111
from django.urls import reverse
1212
from django.views.decorators.http import require_http_methods
1313

14-
from .signals import slack_event_received
14+
from .tasks import receive_slack_signal_task
1515
from .exceptions import SlackAppNotInstalledProperlyException, SlackAccountNotLinkedException, SlackCommandDoesNotExist, \
1616
SlackInteractivityTypeDoesNotExist
1717
from .models import SlackWorkspace, SlackUserMapping
@@ -176,7 +176,7 @@ def slack_events(request):
176176
event_data = data.pop('event')
177177
event_type = event_data.pop('type')
178178

179-
slack_event_received.send(sender=request, event_type=event_type, event_data=event_data, **data)
179+
receive_slack_signal_task.delay(sender=request.get_host(), event_type=event_type, event_data=event_data, **data)
180180
return JsonResponse({})
181181

182182
if data.get("type") == 'app_rate_limited':

0 commit comments

Comments
 (0)