task xxxx is defined in pipeline.py as above