Use BeamDataflowJobTask from luigi.contrib #192
Description
Thanks to @clairemcginty ! BeamDataflowJobTask is added to luigi 2.8.5 (https://github.com/spotify/luigi/blob/2.8.5/luigi/contrib/beam_dataflow.py). We could use it to replace PythonDataflowTask