diff --git a/pda/listdb/ListDB.py b/pda/listdb/ListDB.py index d5c895c..026eede 100755 --- a/pda/listdb/ListDB.py +++ b/pda/listdb/ListDB.py @@ -198,6 +198,7 @@ def _get_one_label(self, name, color, labels): """ resp = requests.get(self.url_labels+'/'+name, auth=self.auth) + resp.connection.close() if resp.status_code == requests.codes.ok: # label found labels.append(name) @@ -205,12 +206,14 @@ def _get_one_label(self, name, color, labels): rep = requests.put(self.url_labels, data=json.dumps({'name': name, 'color': color}), auth=self.auth) + rep.connection.close() if rep.status_code == requests.codes.created: labels.append(name) else: die_msg(PROG_NAME, 'label created failed: ' + name) + def _update_labels(self, cmd): """update **Github Issues** based on the information given by `cmd` :param cmd: dict @@ -222,6 +225,7 @@ def _update_labels(self, cmd): resp = requests.get(self.url_issues+'/'+str(issue_number)+'/labels', auth=self.auth) + resp.connection.close() if resp.status_code == requests.codes.ok: # replacing labels @@ -248,6 +252,7 @@ def _update_labels(self, cmd): die_msg(PROG_NAME, \ 'failed to retrive labels for current issue: '+str(issue_number)) + return labels def _get_labels(self, cmd): @@ -279,6 +284,7 @@ def _get_milestone_number(self, cmd): # look for existing milestone if milestone_title: resp = requests.get(self.url_milestones, auth=self.auth) + resp.connection.close() if resp.status_code == requests.codes.ok: for milestone in resp.json(): @@ -293,6 +299,7 @@ def _get_milestone_number(self, cmd): resp = requests.post(url=self.url_milestones, data=json.dumps({'title': milestone_title}), auth=self.auth) + resp.connection.close() if resp.status_code == requests.codes.created: milestone_number = resp.json()['number'] @@ -354,16 +361,19 @@ def _exec_cmd_on_remote(self, cmd): data=json.dumps(payload), auth=self.auth) success = (resp.status_code == requests.codes.created) + resp.connection.close() elif cmd['CMD'] == 'EDIT': resp = requests.patch(url=url, data=json.dumps(payload), auth=self.auth) success = (resp.status_code == requests.codes.ok) + resp.connection.close() else: # REMOVE resp = requests.patch(url=url, data=json.dumps(payload), auth=self.auth) success = (resp.status_code == requests.codes.ok) + resp.connection.close() return success @@ -433,6 +443,7 @@ def sync_local_dbstore(self): resp = requests.get(self.url_issues, params={'state': 'open'}, auth=self.auth) + resp.connection.close() if resp.status_code == requests.codes.ok: # write issue data into local db store