Rename package and fix configuration files

README.rst

@@ -5,9 +5,9 @@
 |build-status| |coverage| |license| |wheel| |pyversion| |pyimp|
 
 :Version: 4.3.2
-:Web: http://mode.readthedocs.org/
-:Download: http://pypi.org/project/mode
-:Source: http://github.com/ask/mode
+:Web: http://mode-streaming.readthedocs.org/
+:Download: http://pypi.org/project/mode-streaming
+:Source: http://github.com/faust-streaming/mode
 :Keywords: async, service, framework, actors, bootsteps, graph
 
 What is Mode?
@@ -239,19 +239,19 @@ or from source.
 
 To install using `pip`::
 
-    $ pip install -U mode
+    $ pip install -U mode-streaming
 
 .. _installing-from-source:
 
 Downloading and installing from source
 --------------------------------------
 
 Download the latest version of Mode from
-http://pypi.org/project/mode
+http://pypi.org/project/mode-streaming
 
 You can install it by doing the following::
 
-    $ tar xvfz mode-0.0.0.tar.gz
+    $ tar xvfz mode-streaming-0.0.0.tar.gz
     $ cd mode-0.0.0
     $ python setup.py build
     # python setup.py install
@@ -270,7 +270,7 @@ With pip
 You can install the latest snapshot of Mode using the following
 pip command::
 
-    $ pip install https://github.com/ask/mode/zipball/master#egg=mode
+    $ pip install https://github.com/faust-streaming/mode/zipball/master#egg=mode-streaming
 
 FAQ
 ===
@@ -290,7 +290,7 @@ and you can install this as a bundle with Mode:
 
 .. sourcecode:: console
 
-    $ pip install -U mode[gevent]
+    $ pip install -U mode-streaming[gevent]
 
 Then to actually use gevent as the event loop you have to
 execute the following in your entrypoint module (usually where you
@@ -315,7 +315,7 @@ and you can install this as a bundle with Mode:
 
 .. sourcecode:: console
 
-    $ pip install -U mode[eventlet]
+    $ pip install -U mode-streaming[eventlet]
 
 Then to actually use eventlet as the event loop you have to
 execute the following in your entrypoint module (usually where you
@@ -447,26 +447,26 @@ reported by opening an issue or contacting one or more of the project maintainer
 This Code of Conduct is adapted from the Contributor Covenant,
 version 1.2.0 available at http://contributor-covenant.org/version/1/2/0/.
 
-.. |build-status| image:: https://secure.travis-ci.org/ask/mode.png?branch=master
+.. |build-status| image:: https://secure.travis-ci.org/faust-streaming/mode.png?branch=master
     :alt: Build status
-    :target: https://travis-ci.org/ask/mode
+    :target: https://travis-ci.org/faust-streaming/mode
 
-.. |coverage| image:: https://codecov.io/github/ask/mode/coverage.svg?branch=master
-    :target: https://codecov.io/github/ask/mode?branch=master
+.. |coverage| image:: https://codecov.io/github/faust-streaming/mode/coverage.svg?branch=master
+    :target: https://codecov.io/github/faust-streaming/mode?branch=master
 
-.. |license| image:: https://img.shields.io/pypi/l/mode.svg
+.. |license| image:: https://img.shields.io/pypi/l/mode-streaming.svg
     :alt: BSD License
     :target: https://opensource.org/licenses/BSD-3-Clause
 
-.. |wheel| image:: https://img.shields.io/pypi/wheel/mode.svg
+.. |wheel| image:: https://img.shields.io/pypi/wheel/mode-streaming.svg
     :alt: Mode can be installed via wheel
-    :target: http://pypi.org/project/mode/
+    :target: http://pypi.org/project/mode-streaming/
 
-.. |pyversion| image:: https://img.shields.io/pypi/pyversions/mode.svg
+.. |pyversion| image:: https://img.shields.io/pypi/pyversions/mode-streaming.svg
     :alt: Supported Python versions.
-    :target: http://pypi.org/project/mode/
+    :target: http://pypi.org/project/mode-streaming/
 
-.. |pyimp| image:: https://img.shields.io/pypi/implementation/mode.svg
+.. |pyimp| image:: https://img.shields.io/pypi/implementation/mode-streaming.svg
     :alt: Supported Python implementations.
-    :target: http://pypi.org/project/mode/
+    :target: http://pypi.org/project/mode-streaming/
 

mode/__init__.py

@@ -11,7 +11,7 @@
 __version__ = '4.3.2'
 __author__ = 'Robinhood Markets'
 __contact__ = 'opensource@robinhood.com'
-__homepage__ = 'https://github.com/ask/mode'
+__homepage__ = 'https://github.com/faust-streaming/mode'
 __docformat__ = 'restructuredtext'
 
 # -eof meta-

requirements/docs.txt

@@ -1,3 +1,4 @@
+six
 sphinx>=2.2,<3.0
 sphinx_celery>=1.4.8
 sphinx-autodoc-annotation

requirements/typecheck.txt

@@ -1,2 +1,2 @@
-mypy>=0.750
+mypy==0.782
 yarl

setup.cfg

@@ -1,5 +1,5 @@
 [metadata]
-name = mode
+name = mode-streaming
 version = attr: mode.__version__
 author = attr: mode.__author__
 author_email = attr: mode.__contact__

setup.py

@@ -11,7 +11,7 @@ def _pyimp():
         return 'Python'
 from setuptools import find_packages, setup
 
-NAME = 'mode'
+NAME = 'mode-streaming'
 EXTENSIONS = {'eventlet', 'gevent', 'uvloop'}
 E_UNSUPPORTED_PYTHON = '%s 1.0 requires %%s %%s or later!' % (NAME,)
 
@@ -60,7 +60,7 @@ def add_doc(m):
 
 pats = {re_meta: add_default, re_doc: add_doc}
 here = Path(__file__).parent.absolute()
-with open(here / NAME / '__init__.py') as meta_fh:
+with open(here / 'mode' / '__init__.py') as meta_fh:
     meta = {}
     for line in meta_fh:
         if line.strip() == '# -eof meta-':
@@ -73,8 +73,8 @@ def add_doc(m):
 # -*- Installation Requires -*-
 
 
-def strip_comments(l):
-    return l.split('#', 1)[0].strip()
+def strip_comments(line):
+    return line.split('#', 1)[0].strip()
 
 
 def _pip_requirement(req):
@@ -86,7 +86,10 @@ def _pip_requirement(req):
 
 def _reqs(*f):
     path = (Path.cwd() / 'requirements').joinpath(*f)
-    reqs = (strip_comments(l) for l in path.open().readlines())
+    reqs = (
+        strip_comments(line)
+        for line in path.open().readlines()
+    )
     return [_pip_requirement(r) for r in reqs if r]
 
 

t/unit/test_worker.py

@@ -254,7 +254,7 @@ def test_execute_from_commandline(self, worker):
                 worker.execute_from_commandline()
             assert excinfo.value.code == 0
             assert worker._starting_fut is ensure_future.return_value
-            ensure_future.assert_called_once_with(worker.start.return_value, worker.loop)
+            ensure_future.assert_called_once_with(worker.start.return_value, loop=worker.loop)
             worker.stop_and_shutdown.assert_called_once_with()
 
     def test_execute_from_commandline__MemoryError(self, worker):