add missing import of fetch to cluster tasks

XXX these bugs are easy to miss when the worker isn't restarted...
topic models
rename es in es.py to _es

Fixes #19. It wasn't meant to be public anyway; we need a function that
returns a handle on the ES instance, taking it from a config file.