jingrow/gunicorn
1
0
Fork 0
mirror of https://github.com/frappe/gunicorn.git synced 2026-01-14 11:09:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix for issue #3079, worker_class parameter accepts a class

Browse Source
This commit is contained in:
Odysseas Fatouros 2023-10-13 16:15:40 +02:00
parent 430dcdd997
commit ca2ce2c76b
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
gunicorn/config.py
View File

@ -103,18 +103,20 @@ class Config(object):
def worker_class_str(self): def worker_class_str(self):
uri = self.settings['worker_class'].get() uri = self.settings['worker_class'].get()
# are we using a threaded worker? if isinstance(uri, str):
is_sync = uri.endswith('SyncWorker') or uri == 'sync' # are we using a threaded worker?
if is_sync and self.threads > 1: is_sync = uri.endswith('SyncWorker') or uri == 'sync'
return "gthread" if is_sync and self.threads > 1:
return uri return "gthread"
return uri
return uri.__name__
@property @property
def worker_class(self): def worker_class(self):
uri = self.settings['worker_class'].get() uri = self.settings['worker_class'].get()
# are we using a threaded worker? # are we using a threaded worker?
is_sync = uri.endswith('SyncWorker') or uri == 'sync' is_sync = isinstance(uri, str) and (uri.endswith('SyncWorker') or uri == 'sync')
if is_sync and self.threads > 1: if is_sync and self.threads > 1:
uri = "gunicorn.workers.gthread.ThreadWorker" uri = "gunicorn.workers.gthread.ThreadWorker"