MapReduce fails with "wrapped IOException: Broken pipe"

I am trying to implement a MapReduce job with only a map step and no outputs using python. I’ve tested the map logic in a jupyter with c3-remote, but am unable to run it server side.


entity type MyType extends MapReduce <MyTargetType, Void, Void, Void> type key 'MYTYP' {

  @py(env = "myRunTime")
  map: ~


def map(batch, objs, job, subBatch):
    # my map logic here

c3QErrs(MapReduceQueue) returns this error message:

wrapped IOException: Broken pipe

    at (
  Broken pipe

Server version is Does anyone know what is causing this?

1 Like