Si tenés una task así:

```python
@task
def do(a, b, c): pass
```

La llamada sería así:

```python
options = {'queue': 'custom_queue'}
do.apply_async(
    args=[1],
    kwargs={
        'b': 2,
        'c': 3,
    },
    **options
)
```

O sea, las options son para `apply_async`. La función `do()` no acepta el kwarg `queue`, eso es algo de Celery y no del código de la task.