pig extracted to ezflows-task  module