fix/ci

.github/workflows/ci_test.yml

@@ -8,7 +8,14 @@ on:
       - master
   pull_request:
 jobs:
+  wip:
+    if: ${{ !contains(github.event.pull_request.title, 'WIP') }}
+    name: Check for WIP
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v2
   black-test:
+    if: ${{ !contains(github.event.pull_request.title, 'WIP') }}
     name: Black Python code format
     runs-on: ubuntu-latest
     steps:
@@ -24,6 +31,7 @@ jobs:
       - name: Ensure contributor used ("black ./") before commit
         run: black --check .
   test:
+    if: ${{ !contains(github.event.pull_request.title, 'WIP') }}
     runs-on: ubuntu-latest
     strategy:
       matrix:
@@ -39,17 +47,20 @@ jobs:
           python-version: ${{ matrix.python-version }}
 
       - name: Install Poetry
-        uses: dschep/install-poetry-action@v1.2
+        uses: snok/install-poetry@v1.1.1
         with:
           version: 1.1.4
 
       - name: Install Dependencies
         run: |
-          poetry export --without-hashes --dev -f requirements.txt > requirements.txt
-          pip install -r requirements.txt
+          poetry config virtualenvs.create false
+          poetry install
 
       - name: Run Tests
-        run: bash scripts/get-coverage.sh
+        run: |
+          coverage run --concurrency=multiprocessing -m pytest --hypothesis-profile=pypeln
+          coverage combine
+          coverage xml --omit '.venv/*' --omit '*_test.py'
 
       - name: Upload coverage
         uses: codecov/codecov-action@v1

benchmarks/100_million_downloads/client-pypeln-idiomatic.py

@@ -19,7 +19,9 @@ async def fetch(url):
                 return await response.read()
 
         await pl.task.each(
-            fetch, urls, workers=limit,
+            fetch,
+            urls,
+            workers=limit,
         )
 
 

conftest.py

@@ -0,0 +1,3 @@
+from hypothesis import settings
+
+settings.register_profile("pypeln", deadline=1000)