Project

General

Profile

« Previous | Next » 

Revision 1886

Added by Aaron Marcuse-Kubitza over 12 years ago

bin/map: Share locals() with the pool at various times to try to get as many unpicklable values into the shared vars as possible

View differences:

bin/map
283 283 
            row_ct += process_input(root, row_ready, map_path)
284 284 
        return row_ct
285 285
286 
    pool.share_vars(locals())
286 287 
    if out_is_db:
287 288 
        import db_xml
288 289
......
290 291 
        try:
291 292 
            if redo: sql.empty_db(out_db)
292 293 
            row_ins_ct_ref = [0]
294 
            pool.share_vars(locals())
293 295
294 296 
            def row_ready(row_num, input_row):
295 297 
                def on_error(e):
......
297 299 
                    exc.add_msg(e, term.emph('input row:')+'\n'+str(input_row))
298 300 
                    exc.add_msg(e, term.emph('output row:')+'\n'+str(root))
299 301 
                    ex_tracker.track(e, row_num)
300 
                pool.share(on_error)
302 
                pool.share_vars(locals())
301 303
302 304 
                xml_func.process(root, on_error)
303 305 
                if not xml_dom.is_empty(root):

Also available in: Unified diff