def pipe_createrss(context=None, _INPUT=None, conf=None, **kwargs):
    """An operator that converts a source into an RSS stream. Not loopable.

    """
    conf = DotDict(conf)

    for item in _INPUT:
        item = DotDict(item)

        yield {
            value: item.get(conf.get(key, **kwargs))
            for key, value in RSS_FIELDS.items()}
def pipe_createrss ( context = None , _INPUT = None , conf = None , ** kwargs ) : conf = DotDict ( conf ) for item in _INPUT : item = DotDict ( item ) yield { value : item . get ( conf . get ( key , ** kwargs ) ) for key , value in RSS_FIELDS . items ( ) }
An operator that converts a source into an RSS stream. Not loopable.