def get_download_pipeline(in_fd, out_fd, gpg=False, lzop=True):
 commands = []
 if gpg:
  commands.append(GPGDecryptionFilter())
 if lzop:
  commands.append(LZODecompressionFilter())
 return Pipeline(commands, in_fd, out_fd)

def get_download_pipeline ( in_fd , out_fd , gpg = False , lzop = True ) : commands = [ ] if gpg : commands . append ( GPGDecryptionFilter ( ) ) if lzop : commands . append ( LZODecompressionFilter ( ) ) return Pipeline ( commands , in_fd , out_fd )
create a pipeline to process a file after downloading .