I initialized a webdriver object with celery but reported this error on windows.
set_nonblocking() on a file object with no setblocking() method (Windows pipes don't support non-blocking I/O)
Code trial:
celery_app = Celery()
celery_app.config_from_object('config.celeryconfig')
from celery import Task
from selenium import webdriver
eventlet.monkey_patch(os=False)
class GetDriver(Task):
test = 'test'
chromedriver_path = "chromedriver.exe"
driver = webdriver.Chrome(executable_path=chromedriver_path)
@celery_app.task(base=GetDriver, bind=True)
def demo(self, params):
print(params)
print(self.test)
Can cellery initialize a webdriver object at initialization?