zuul
/
zuul
Code Issues Proposed changes

Merge "connections: remove unused getSchema procedure"

This commit is contained in:
Zuul 2019-02-18 18:58:02 +00:00 committed by Gerrit Code Review
parent d854806183 820a035e44
commit 6e53e4aecd
6 changed files with 0 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
zuul/driver/gerrit/gerritconnection.py
View File

@ -26,7 +26,6 @@ import pprint
import shlex import shlex
import queue import queue
import urllib.parse import urllib.parse
import voluptuous as v
import requests import requests
from typing import Dict, List from typing import Dict, List
@ -1079,8 +1078,3 @@ class GerritConnection(BaseConnection):
def _start_event_connector(self): def _start_event_connector(self):
self.gerrit_event_connector = GerritEventConnector(self) self.gerrit_event_connector = GerritEventConnector(self)
self.gerrit_event_connector.start() self.gerrit_event_connector.start()
def getSchema():
gerrit_connection = v.Any(str, v.Schema(dict))
return gerrit_connection

7
zuul/driver/git/gitconnection.py
View File

@ -20,8 +20,6 @@ import logging
import urllib import urllib
import threading import threading
import voluptuous as v
from zuul.connection import BaseConnection from zuul.connection import BaseConnection
from zuul.driver.git.gitmodel import GitTriggerEvent, EMPTY_GIT_REF from zuul.driver.git.gitmodel import GitTriggerEvent, EMPTY_GIT_REF
from zuul.model import Ref, Branch from zuul.model import Ref, Branch
@ -252,8 +250,3 @@ class GitConnection(BaseConnection):
self.baseurl, self.baseurl,
self.poll_timeout) self.poll_timeout)
self.watcher_thread.start() self.watcher_thread.start()
def getSchema():
git_connection = v.Any(str, v.Schema(dict))
return git_connection

6
zuul/driver/github/githubconnection.py
View File

@ -32,7 +32,6 @@ from cachecontrol.heuristics import BaseHeuristic
import iso8601 import iso8601
import jwt import jwt
import requests import requests
import voluptuous as v
import github3 import github3
import github3.exceptions import github3.exceptions
@ -1614,8 +1613,3 @@ def _status_as_tuple(status):
context = status.get('context') context = status.get('context')
state = status.get('state') state = status.get('state')
return (user, context, state) return (user, context, state)
def getSchema():
github_connection = v.Any(str, v.Schema(dict))
return github_connection

5
zuul/driver/mqtt/mqttconnection.py
View File

@ -15,7 +15,6 @@
import logging import logging
import json import json
import voluptuous as v
import paho.mqtt.client as mqtt import paho.mqtt.client as mqtt
from zuul.connection import BaseConnection from zuul.connection import BaseConnection
@ -82,7 +81,3 @@ class MQTTConnection(BaseConnection):
except Exception: except Exception:
self.log.exception( self.log.exception(
"Could not publish message to topic '%s' via mqtt", topic) "Could not publish message to topic '%s' via mqtt", topic)
def getSchema():
return v.Any(str, v.Schema(dict))

6
zuul/driver/smtp/smtpconnection.py
View File

@ -13,7 +13,6 @@
# under the License. # under the License.
import logging import logging
import voluptuous as v
import smtplib import smtplib
from email.mime.text import MIMEText from email.mime.text import MIMEText
@ -66,8 +65,3 @@ class SMTPConnection(BaseConnection):
s.quit() s.quit()
except Exception as e: except Exception as e:
self.log.warning("Error sending mail via SMTP: %s", e) self.log.warning("Error sending mail via SMTP: %s", e)
def getSchema():
smtp_connection = v.Any(str, v.Schema(dict))
return smtp_connection

6
zuul/driver/sql/sqlconnection.py
View File

@ -21,7 +21,6 @@ import sqlalchemy as sa
from sqlalchemy.ext.declarative import declarative_base from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import orm from sqlalchemy import orm
import sqlalchemy.pool import sqlalchemy.pool
import voluptuous
from zuul.connection import BaseConnection from zuul.connection import BaseConnection
@ -320,8 +319,3 @@ class SQLConnection(BaseConnection):
"""Return a list of BuildSet objects""" """Return a list of BuildSet objects"""
with self.getSession() as db: with self.getSession() as db:
return db.getBuildsets(*args, **kw) return db.getBuildsets(*args, **kw)
def getSchema():
sql_connection = voluptuous.Any(str, voluptuous.Schema(dict))
return sql_connection