// function in the variable flow_process
interpreter.set("flow_process", flowProcess);
// We need to run the main file first so that imports etc. are defined,
// and nested functions can also be used
interpreter.execfile(sourceDir + (String) jobConf.get("pycascading.main_file"));
return interpreter;
}
// We need to delay the deserialization of the Python functions up to this
// point, since the sources are in the distributed cache, whose location is in