Project

General

Profile

« Previous | Next » 

Revision 1886

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:

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