support on_block callback in inqueue.write. Temporary fix for celery/celery#1306