Generate a parametrized Disco job. See http://disco.readthedocs.org/en/latest/start/tutorial_2.html for example of class based map reduce jobs.

discojob.py

def generate_job(param):
  """Generate a job the yields only rows identical to `param`."""
  class CsvInnerJoiner(Job):
      def map(self, rows, params):
        for row in rows:
          if row == param:
            yield row, "found"