Release v0.0.2 and prepare for pytask 0.0.5. (#1)

Author: tobiasraabe

.conda/meta.yaml

@@ -21,7 +21,7 @@ requirements:
   run:
     - python >=3.6
     - cloudpickle
-    - pytask >=0.0.2
+    - pytask >=0.0.5
 
 test:
   requires:

.pre-commit-config.yaml

@@ -1,6 +1,6 @@
 repos:
 -   repo: https://github.com/pre-commit/pre-commit-hooks
-    rev: v3.1.0
+    rev: v3.2.0
     hooks:
     -   id: check-added-large-files
         args: ['--maxkb=100']
@@ -10,12 +10,12 @@ repos:
     -   id: debug-statements
     -   id: end-of-file-fixer
 -   repo: https://github.com/asottile/pyupgrade
-    rev: v2.7.1
+    rev: v2.7.2
     hooks:
     -   id: pyupgrade
         args: [--py36-plus]
 -   repo: https://github.com/asottile/reorder_python_imports
-    rev: v2.3.0
+    rev: v2.3.5
     hooks:
     -   id: reorder-python-imports
 -   repo: https://github.com/psf/black

CHANGES.rst

@@ -6,7 +6,13 @@ chronological order. Releases follow `semantic versioning <https://semver.org/>`
 all releases are available on `Anaconda.org <https://anaconda.org/pytask/pytask-parallel>`_.
 
 
+0.0.2 - 2020-08-12
+------------------
+
+- :gh:`2` prepares the plugin for pytask 0.0.5.
+
+
 0.0.1 - 2020-07-17
 ------------------
 
-- :gh:`1` combined the whole effort which went into releasing v0.0.1.
+- Initial commit which combined the whole effort to release v0.0.1.

README.rst

@@ -21,6 +21,13 @@ pytask-parallel
 Parallelize the execution of tasks with `pytask-parallel` which is a plugin for `pytask
 <https://github.com/pytask-dev/pytask>`_.
 
+Install the plugin via ``conda`` with
+
+.. code-block:: bash
+
+    $ conda config --add channels conda-forge --add channels pytask
+    $ conda install pytask-parallel
+
 The plugin uses the ``ProcessPoolExecutor`` or ``ThreadPoolExecutor`` in the
 `concurrent.futures <https://docs.python.org/3/library/concurrent.futures.html>`_ module
 to execute tasks asynchronously.

environment.yml

@@ -3,7 +3,7 @@ channels:
   - conda-forge
   - pytask
 dependencies:
-  - python=3.7
+  - python
   - pip
 
   # Conda
@@ -12,10 +12,11 @@ dependencies:
   - conda-verify
 
   # Package dependencies
-  - pytask
+  - pytask >= 0.0.5
   - cloudpickle
 
   # Misc
+  - bump2version
   - jupyterlab
   - matplotlib
   - pdbpp

setup.cfg

@@ -1,12 +1,10 @@
 [bumpversion]
-current_version = 0.0.1
+current_version = 0.0.2
 parse = (?P<major>\d+)\.(?P<minor>\d+)(\.(?P<patch>\d+))(\-?((dev)?(?P<dev>\d+))?)
-serialize =
-    {major}.{minor}.{patch}dev{dev}
-    {major}.{minor}.{patch}
+serialize = 
+	{major}.{minor}.{patch}dev{dev}
+	{major}.{minor}.{patch}
 
 [bumpversion:file:setup.py]
 
-[bumpversion:file:docs/conf.py]
-
-[bumpversion:file:src/parallel/__init__.py]
+[bumpversion:file:src/pytask_parallel/__init__.py]

setup.py

@@ -3,7 +3,7 @@
 
 setup(
     name="pytask-parallel",
-    version="0.0.1",
+    version="0.0.2",
     packages=find_packages(where="src"),
     package_dir={"": "src"},
     entry_points={"pytask": ["pytask_parallel = pytask_parallel.plugin"]},

src/pytask_parallel/__init__.py

@@ -0,0 +1 @@
+__version__ = "0.0.2"

src/pytask_parallel/cli.py

@@ -1,8 +1,8 @@
 import click
-import pytask
+from _pytask.config import hookimpl
 
 
-@pytask.hookimpl
+@hookimpl
 def pytask_add_parameters_to_cli(command):
     additional_parameters = [
         click.Option(

src/pytask_parallel/config.py

@@ -1,10 +1,10 @@
 import os
 
-import pytask
-from pytask.shared import get_first_not_none_value
+from _pytask.config import hookimpl
+from _pytask.shared import get_first_not_none_value
 
 
-@pytask.hookimpl
+@hookimpl
 def pytask_parse_config(config, config_from_cli, config_from_file):
     config["n_workers"] = get_first_not_none_value(
         config_from_cli, config_from_file, key="n_workers", default=1
@@ -20,7 +20,7 @@ def pytask_parse_config(config, config_from_cli, config_from_file):
     )
 
 
-@pytask.hookimpl
+@hookimpl
 def pytask_post_parse(config):
     # Disable parallelization if debugging is enabled.
     if config["pdb"] or config["trace"]:

src/pytask_parallel/execute.py

@@ -5,26 +5,25 @@
 
 import cloudpickle
 import networkx as nx
-import pytask
-from pytask.report import ExecutionReport
+from _pytask.config import hookimpl
+from _pytask.report import ExecutionReport
 from pytask_parallel.scheduler import TopologicalSorter
 
-
 PARALLEL_BACKEND = {
     "processes": ProcessPoolExecutor,
     "threads": ThreadPoolExecutor,
 }
 
 
-@pytask.hookimpl
+@hookimpl
 def pytask_post_parse(config):
     if config["parallel_backend"] == "processes":
         config["pm"].register(ProcessesNameSpace)
     elif config["parallel_backend"] == "threads":
         config["pm"].register(ThreadsNameSpace)
 
 
-@pytask.hookimpl(tryfirst=True)
+@hookimpl(tryfirst=True)
 def pytask_execute_create_scheduler(session):
     if session.config["n_workers"] > 1:
         task_names = {task.name for task in session.tasks}
@@ -40,7 +39,7 @@ def pytask_execute_create_scheduler(session):
         return scheduler
 
 
-@pytask.hookimpl(tryfirst=True)
+@hookimpl(tryfirst=True)
 def pytask_execute_build(session):
     if session.config["n_workers"] > 1:
         reports = []
@@ -123,7 +122,7 @@ def pytask_execute_build(session):
 
 
 class ProcessesNameSpace:
-    @pytask.hookimpl(tryfirst=True)
+    @hookimpl(tryfirst=True)
     def pytask_execute_task(session, task):  # noqa: N805
         if session.config["n_workers"] > 1:
             bytes_ = cloudpickle.dumps(task)
@@ -136,7 +135,7 @@ def unserialize_and_execute_task(bytes_):
 
 
 class ThreadsNameSpace:
-    @pytask.hookimpl(tryfirst=True)
+    @hookimpl(tryfirst=True)
     def pytask_execute_task(session, task):  # noqa: N805
         if session.config["n_workers"] > 1:
             return session.executor.submit(task.execute)

src/pytask_parallel/plugin.py

@@ -1,10 +1,10 @@
-import pytask
+from _pytask.config import hookimpl
 from pytask_parallel import cli
 from pytask_parallel import config
 from pytask_parallel import execute
 
 
-@pytask.hookimpl
+@hookimpl
 def pytask_add_hooks(pm):
     pm.register(cli)
     pm.register(config)

tests/test_config.py

@@ -1,7 +1,7 @@
 import os
 
 import pytest
-from pytask.main import main
+from pytask import main
 
 
 @pytest.mark.end_to_end

tests/test_execute.py

@@ -4,7 +4,7 @@
 from concurrent.futures import ThreadPoolExecutor
 
 import pytest
-from pytask.main import main
+from pytask import main
 from pytask_parallel.execute import ProcessesNameSpace
 from pytask_parallel.execute import ThreadsNameSpace
 

tox.ini

@@ -9,7 +9,7 @@ basepython = python
 [testenv:pytest]
 conda_deps =
     cloudpickle
-    pytask >=0.0.2
+    pytask >=0.0.5
     pytest
     pytest-cov
     pytest-xdist