Trying to still fix:

2022-02-04 03:30:39,971,971ms [PID: 1278984] workers.pull_request_worker.50471 [DEBUG] Pull Requests model. ERROR: organize_needed_data() takes from 3 to 4 positional arguments but 5 were given
Traceback (most recent call last):
  File "/bigdisk/augur-vmware/workers/pull_request_worker/pull_request_worker.py", line 723, in pull_requests_model
    pk_source_prs = self._get_pk_source_prs()
  File "/bigdisk/augur-vmware/workers/pull_request_worker/pull_request_worker.py", line 676, in _get_pk_source_prs
    source_prs = self.paginate_endpoint(
  File "/bigdisk/augur-vmware/workers/worker_git_integration.py", line 1274, in paginate_endpoint
    need_insertion, need_update = self.organize_needed_data(
TypeError: organize_needed_data() takes from 3 to 4 positional arguments but 5 were given
2022-02-04 03:30:40,000,0ms [PID: 1278984] workers.pull_request_worker.50471 [INFO] Worker completed this task in -70.00859665870667 seconds.

2022-02-04 03:30:40,019,19ms [PID: 1278984] workers.pull_request_worker.50471 [INFO] Recorded job completion for: {'worker_id': 'workers.pull_request_worker.50471', 'job_type': 'MAINTAIN', 'repo_id': 27044, 'job_model': 'pull_requests', 'github_url': 'https://github.com/vmware/clarity'}

workers/worker_git_integration.py

@@ -1272,9 +1272,12 @@ def paginate_endpoint(
 
         if forward_pagination:
             need_insertion, need_update = self.organize_needed_data(
-                all_data, table_values, list(table.primary_key)[0].name, action_map
+                all_data, table_values, action_map
             )
 
+            # list(table.primary_key)[0].name, -- organize_needed_data takes self as a parameter. This seems out of place and is 
+            # causing an error - SPG 2/3/2022
+
         return {
             'insert': need_insertion,
             'update': need_update,