Hello! I am using dagster-celery and pushing certain ops out to their own dedicated workers using the dagster-celery/queue tag. I have a particular task that I need to override the celery base task class to provide an object to all the tasks of these particular workers. The object has a long start up time so it should start up with the worker and be available for all subsequent tasks the worker executes. I've gone through the dagster-celery code, but can't find a convenient way to override the base task class in for particular ops. Is there a way to accomplish this? Or potentially another way of handling a situation where an op/task needs access to an object with high start up overhead? Thanks!!