| 1368 | |
| 1369 | |
| 1370 | def test_task_manual_processing_node(self): |
| 1371 | user = User.objects.get(username="testuser") |
| 1372 | project = Project.objects.create(name="User Test Project", owner=user) |
| 1373 | task = Task.objects.create(project=project, name="Test", auto_processing_node=False) |
| 1374 | |
| 1375 | # Bring a processing node online |
| 1376 | pnode = ProcessingNode.objects.create(hostname="invalid-host", port=11223) |
| 1377 | assign_perm('view_processingnode', user, pnode) |
| 1378 | |
| 1379 | pnode.last_refreshed = timezone.now() |
| 1380 | pnode.save() |
| 1381 | self.assertTrue(pnode.is_online()) |
| 1382 | |
| 1383 | worker.tasks.process_pending_tasks() |
| 1384 | |
| 1385 | # A processing node should not have been assigned because we asked |
| 1386 | # not to via auto_processing_node = false |
| 1387 | task.refresh_from_db() |
| 1388 | self.assertTrue(task.processing_node is None) |
| 1389 | |
| 1390 | def test_task_multifile_uploads(self): |
| 1391 | with start_processing_node(): |