Procházet zdrojové kódy

fix processing test

Bastien Sevajol před 6 roky
rodič
revize
740339e3a6
1 změnil soubory, kde provedl 6 přidání a 0 odebrání
  1. 6 0
      tests/test_processing.py

+ 6 - 0
tests/test_processing.py Zobrazit soubor

43
             process_count=available_cores,
43
             process_count=available_cores,
44
             job=self.make_job_with_scalar,
44
             job=self.make_job_with_scalar,
45
         )
45
         )
46
+        process_manager.start_workers()
46
 
47
 
47
         data = list(range(100))
48
         data = list(range(100))
48
 
49
 
59
             process_count=1,
60
             process_count=1,
60
             job=self.make_job_with_scalar,
61
             job=self.make_job_with_scalar,
61
         )
62
         )
63
+        process_manager.start_workers()
62
 
64
 
63
         data = list(range(100))
65
         data = list(range(100))
64
         results = process_manager.make_them_work(data)
66
         results = process_manager.make_them_work(data)
75
             process_count=available_cores,
77
             process_count=available_cores,
76
             job=self.make_job_with_object,
78
             job=self.make_job_with_object,
77
         )
79
         )
80
+        process_manager.start_workers()
78
 
81
 
79
         data = [MyFakeClass(v) for v in range(100)]
82
         data = [MyFakeClass(v) for v in range(100)]
80
         final_result = 0
83
         final_result = 0
103
             process_count=available_cores,
106
             process_count=available_cores,
104
             job=job,
107
             job=job,
105
         )
108
         )
109
+        process_manager.start_workers()
106
 
110
 
107
         results = process_manager.make_them_work(None)
111
         results = process_manager.make_them_work(None)
108
         process_manager.terminate()
112
         process_manager.terminate()
126
             process_count=available_cores,
130
             process_count=available_cores,
127
             job=job,
131
             job=job,
128
         )
132
         )
133
+        process_manager.start_workers()
129
 
134
 
130
         foo = Foo()
135
         foo = Foo()
131
         foo.counter = 42
136
         foo.counter = 42
158
             process_count=available_cores,
163
             process_count=available_cores,
159
             job=job,
164
             job=job,
160
         )
165
         )
166
+        process_manager.start_workers()
161
 
167
 
162
         shared.set('foo_1', 42)
168
         shared.set('foo_1', 42)
163
         shared.commit()
169
         shared.commit()