Make sure to cleanup only the runs that are assigned to the worker.

README.rst

@@ -121,6 +121,13 @@ For starting the worker, you can use the ``job_runner_worker`` command::
 Changes
 -------
 
+v2.0.1
+~~~~~~
+
+* Make sure to only cleanup runs that are assigned to the worker. This version
+  is dependent on ``job-runner>=3.0.1``.
+
+
 v2.0.0
 ~~~~~~
 

job_runner_worker/__init__.py

@@ -1 +1 @@
-__version__ = '2.0.0'
+__version__ = '2.0.1'

job_runner_worker/cleanup.py

@@ -24,6 +24,7 @@ def reset_incomplete_runs():
             config.get('job_runner_worker', 'run_resource_uri'),
             params={
                 'state': state,
+                'worker__api_key': config.get('job_runner_worker', 'api_key'),
             }
         ))
 

job_runner_worker/tests/unit/test_cleanup.py

@@ -17,7 +17,8 @@ def test_reset_incomplete_runs(self, config, Run):
         """
         def config_side_effect(*args):
             return {
-                ('job_runner_worker', 'run_resource_uri'): '/api/run/'
+                ('job_runner_worker', 'run_resource_uri'): '/api/run/',
+                ('job_runner_worker', 'api_key'): 'test_api_key',
             }[args]
 
         config.get.side_effect = config_side_effect
@@ -29,8 +30,14 @@ def config_side_effect(*args):
         reset_incomplete_runs()
 
         self.assertEqual([
-            call('/api/run/', params={'state': 'in_queue'}),
-            call('/api/run/', params={'state': 'started'}),
+            call('/api/run/', params={
+                'state': 'in_queue',
+                'worker__api_key': 'test_api_key',
+            }),
+            call('/api/run/', params={
+                'state': 'started',
+                'worker__api_key': 'test_api_key',
+            }),
         ], Run.get_list.call_args_list)
 
         incomplete_run.patch.assert_called_once_with({