arb-pipe.yaml

steps:
  - name: pypyr.steps.echo
    comment: if you want to see the echo output, remember to set loglevel <=25
    foreach: '{input_collection}'
    in:
      echoMe: just an echo with {i.arbfield}
  - name: pypyr.steps.contextsetf
    in:
      contextSetf:
        newkey: arbitrary value set in pipeline
        more_complex_obj:
          - one
          - two
          - a: b
            c: d
            e: 
              - e.1
              - e.2

run-pypyr-with-direct-context-injection.py

# optional. if you want to see logging output from pypyr, set log level <=25.
# import logging
# logging.basicConfig(level=25)


import pypyr.pipelinerunner

# this will load ./arb-pipe.yaml
pipeline_name = 'arb-pipe'

# you prob will have some code to get your queryset here like this:
# django_queryset_results = Entry.objects.filter(pub_date__year=2006)

# instead, just giving it a arbitrary hand-coded collection


class MyModelEntity:
    def __init__(self, arb_field):
        self.arbfield = arb_field


django_queryset_results = [
    MyModelEntity('value 1'),
    MyModelEntity('value 2'),
    MyModelEntity('value 3')]

# prepare a dict to initialize context
input_dict = {
    'arbkey': 'arb value',
    'input_collection': django_queryset_results
}

context_out = pypyr.pipelinerunner.main_with_context(
    pipeline_name=pipeline_name,
    dict_in=input_dict)

# context_out contains context + any mutations to it after pipeline completes
assert context_out['arbkey'] == 'arb value'
print(context_out['newkey'])
print(context_out['more_complex_obj'])