It seems much more convenient to place "on_task_change" callback directly into the 'queue.create_tube' constructor