Skip to content

GitLab

  • Menu
Projects Groups Snippets
    • Loading...
  • Help
    • Help
    • Support
    • Community forum
    • Submit feedback
    • Contribute to GitLab
  • Sign in / Register
  • A aisdb
  • Project information
    • Project information
    • Activity
    • Labels
    • Planning hierarchy
    • Members
  • Repository
    • Repository
    • Files
    • Commits
    • Branches
    • Tags
    • Contributors
    • Graph
    • Compare
  • Issues 6
    • Issues 6
    • List
    • Boards
    • Service Desk
    • Milestones
  • Merge requests 0
    • Merge requests 0
  • CI/CD
    • CI/CD
    • Pipelines
    • Jobs
    • Schedules
  • Deployments
    • Deployments
    • Environments
    • Releases
  • Monitor
    • Monitor
    • Incidents
  • Packages & Registries
    • Packages & Registries
    • Package Registry
    • Infrastructure Registry
  • Analytics
    • Analytics
    • Value stream
    • CI/CD
    • Repository
  • Wiki
    • Wiki
  • Snippets
    • Snippets
  • Activity
  • Graph
  • Create a new issue
  • Jobs
  • Commits
  • Issue Boards
Collapse sidebar
  • public_projects
  • aisdb
  • Issues
  • #15

Closed
Open
Created Jul 28, 2022 by Matthew@matt_s☕Maintainer

Network graph fails when run with a process pool

Need to convert results from DBQuery().gen_qry() into serializable format to enable multiprocessing

python-test  | ____________________ test_graph_CSV_parallel_marinetraffic _____________________                                
python-test  | Traceback (most recent call last):                                                                              
python-test  |   File "/home/ais_env/aisdb/tests/test_09_network_graph.py", line 173, in test_graph_CSV_parallel_marinetraffic 
python-test  |     _ = graph(                                                                                                  
python-test  |   File "/home/ais_env/aisdb/network_graph.py", line 439, in graph                                               
python-test  |     p.map(fcn, tracks)                                                                                          
python-test  |   File "/usr/lib/python3.10/multiprocessing/pool.py", line 364, in map                                          
python-test  |     return self._map_async(func, iterable, mapstar, chunksize).get()  
python-test  |   File "/usr/lib/python3.10/multiprocessing/pool.py", line 771, in get
python-test  |     raise self._value                                                                                           
python-test  |   File "/usr/lib/python3.10/multiprocessing/pool.py", line 537, in _handle_tasks
python-test  |     put(task)                                                                                                   
python-test  |   File "/usr/lib/python3.10/multiprocessing/connection.py", line 211, in send
python-test  |     self._send_bytes(_ForkingPickler.dumps(obj))                             
python-test  |   File "/usr/lib/python3.10/multiprocessing/reduction.py", line 51, in dumps
python-test  |     cls(buf, protocol).dump(obj)                                                                                
python-test  | TypeError: cannot pickle 'sqlite3.Row' object
Assignee
Assign to
Time tracking