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`
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