Smalyshev has uploaded a new change for review.
https://gerrit.wikimedia.org/r/284604
Change subject: Tox test configuration
......................................................................
Tox test configuration
Change-Id: I1575a7b5632ff81f869845c83ea247bd8ca807b6
---
M .gitignore
M handlers/Dump.py
M handlers/Memcached.py
M kafka-watcher.py
A requirements.txt
A setup.cfg
A tox.ini
7 files changed, 43 insertions(+), 10 deletions(-)
git pull ssh://gerrit.wikimedia.org:29418/mediawiki/services/kafka-watcher
refs/changes/04/284604/1
diff --git a/.gitignore b/.gitignore
index 0d20b64..aec3d96 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1 +1,2 @@
*.pyc
+.tox/
diff --git a/handlers/Dump.py b/handlers/Dump.py
index 6805d70..48f9dfe 100644
--- a/handlers/Dump.py
+++ b/handlers/Dump.py
@@ -1,8 +1,8 @@
class Dump(object):
-
- def __init__(self, **params):
- print(params)
-
- def handle(self, topic, message):
- print(topic)
- print(message)
+
+ def __init__(self, **params):
+ print(params)
+
+ def handle(self, topic, message):
+ print(topic)
+ print(message)
diff --git a/handlers/Memcached.py b/handlers/Memcached.py
index 3b45cff..e6e231a 100644
--- a/handlers/Memcached.py
+++ b/handlers/Memcached.py
@@ -1,6 +1,9 @@
import memcache
+import time
+
class Memcached(object):
+
def __init__(self, hostname, **params):
self.mc = memcache.Client([hostname])
@@ -16,7 +19,7 @@
purge_time = time.time() + message.get('uto', 0)
text = text.replace('$UNIXTIME$', '%.6f' % purge_time)
# print("Set {0}-{1}-{2}".format(message['key'].encode('utf-8'), text,
int(message['ttl'])))
- self.mc.set(message['key'].encode('utf-8'), text, int(message['ttl']) )
+ self.mc.set(message['key'].encode('utf-8'), text, int(message['ttl']))
def delete(self, message):
- self.mc.delete(message['key'])
\ No newline at end of file
+ self.mc.delete(message['key'])
diff --git a/kafka-watcher.py b/kafka-watcher.py
index b336742..0e49860 100755
--- a/kafka-watcher.py
+++ b/kafka-watcher.py
@@ -38,7 +38,7 @@
print("Could not parse data, meh")
continue
try:
- handlers[msg.topic].handle(msg.topic, data)
+ handlers[msg.topic].handle(msg.topic, data)
except:
e = sys.exc_info()
print("Oops, something happened: " + str(e))
diff --git a/requirements.txt b/requirements.txt
new file mode 100644
index 0000000..04741d5
--- /dev/null
+++ b/requirements.txt
@@ -0,0 +1,3 @@
+yaml
+kafka
+memcache
diff --git a/setup.cfg b/setup.cfg
new file mode 100644
index 0000000..b7b70a3
--- /dev/null
+++ b/setup.cfg
@@ -0,0 +1,5 @@
+# configuration for flake8
+[flake8]
+# Raise the default 79 limit
+max-line-length = 120
+ignore = E128
diff --git a/tox.ini b/tox.ini
new file mode 100644
index 0000000..00c9e9d
--- /dev/null
+++ b/tox.ini
@@ -0,0 +1,21 @@
+# Tox configuration
+[tox]
+minversion = 1.6
+skipsdist = True
+# List the environment that will be run by default
+envlist = flake8, py27
+
+[testenv]
+# Default configuration. py26 and py27 will end up using this
+setenv = VIRTUAL_ENV={envdir}
+
+# Settings specific to the flake8 environment
+[testenv:flake8]
+# The command to run:
+commands = flake8
+# We only need flake8 when linting, we do not care about the project
dependencies
+deps = flake8
+
+[testenv:venv]
+# Let you pass additional arguments when invoking tox
+commands = {posargs}
--
To view, visit https://gerrit.wikimedia.org/r/284604
To unsubscribe, visit https://gerrit.wikimedia.org/r/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: I1575a7b5632ff81f869845c83ea247bd8ca807b6
Gerrit-PatchSet: 1
Gerrit-Project: mediawiki/services/kafka-watcher
Gerrit-Branch: master
Gerrit-Owner: Smalyshev <smalys...@wikimedia.org>
_______________________________________________
MediaWiki-commits mailing list
MediaWiki-commits@lists.wikimedia.org
https://lists.wikimedia.org/mailman/listinfo/mediawiki-commits
