Fix the issues with flake8 and add some todos.

Makefile

@@ -11,13 +11,16 @@ bump-minor:
 bump-major:
 	$(BUMPVERSION) major
 
-clean: clean-pyc clean-build
+clean: clean-pyc clean-build clean-test
 
 clean-dist: clean
 
 clean-build:
 	rm -rf build/ dist/ .eggs/ *.egg-info/ .tox/ .coverage cover/
 
+clean-test:
+	rm -rf .pytest_cache/
+
 clean-pyc:
 	-find . -type f -a \( -name "*.pyc" -o -name "*$$py.class" \) | xargs rm
 	-find . -type d -name "__pycache__" | xargs rm -r

README.md

@@ -86,6 +86,9 @@ Below shows the schema of checkpointing:
 
 ## Todo
 
+* Add type checking with `mypy` 
+* Add the config for travis CI
+* Add code coverage check
 * Support other storage solutions (mysql, dynamodb, redis, etc.) for checkpointing  
 * Rebalance when the number of shards changes
 * Allow kcpy to run on multiple machines

kcpy/checkpoint.py

@@ -14,8 +14,8 @@ def __init__(self, sqlite_file_path, db_name, consumer_name: str, stream_name: s
     def init_db(self):
         conn = sqlite3.connect(self.sqlite_file_path)
         c = conn.cursor()
-        c.execute(f'''CREATE TABLE IF NOT EXISTS {self.db_name} 
-                     (consumer_name text, stream_name text, shard_id text, seq_no text)''')
+        c.execute(f'CREATE TABLE IF NOT EXISTS {self.db_name}'
+                  '(consumer_name text, stream_name text, shard_id text, seq_no text)')
         conn.commit()
         conn.close()