[pre-commit.ci] pre-commit autoupdate (#655)
Co-authored-by: pre-commit-ci[bot] <66853113+pre-commit-ci[bot]@users.noreply.github.com>
This commit is contained in:
committed by
GitHub
parent
f861f1667d
commit
260211603e
@@ -1,6 +1,6 @@
|
|||||||
repos:
|
repos:
|
||||||
- repo: https://github.com/psf/black
|
- repo: https://github.com/psf/black
|
||||||
rev: 20.8b1
|
rev: 21.4b0
|
||||||
hooks:
|
hooks:
|
||||||
- id: black
|
- id: black
|
||||||
args: [--safe, --quiet, --target-version, py35]
|
args: [--safe, --quiet, --target-version, py35]
|
||||||
@@ -17,7 +17,7 @@ repos:
|
|||||||
hooks:
|
hooks:
|
||||||
- id: flake8
|
- id: flake8
|
||||||
- repo: https://github.com/asottile/pyupgrade
|
- repo: https://github.com/asottile/pyupgrade
|
||||||
rev: v2.12.0
|
rev: v2.13.0
|
||||||
hooks:
|
hooks:
|
||||||
- id: pyupgrade
|
- id: pyupgrade
|
||||||
args: [--py3-plus]
|
args: [--py3-plus]
|
||||||
|
|||||||
@@ -14,7 +14,7 @@ from queue import Empty, Queue
|
|||||||
|
|
||||||
|
|
||||||
class Interrupted(KeyboardInterrupt):
|
class Interrupted(KeyboardInterrupt):
|
||||||
""" signals an immediate interruption. """
|
"""signals an immediate interruption."""
|
||||||
|
|
||||||
|
|
||||||
class DSession:
|
class DSession:
|
||||||
|
|||||||
@@ -15,36 +15,36 @@ import pytest
|
|||||||
|
|
||||||
|
|
||||||
def pytest_xdist_setupnodes(config, specs):
|
def pytest_xdist_setupnodes(config, specs):
|
||||||
""" called before any remote node is set up. """
|
"""called before any remote node is set up."""
|
||||||
|
|
||||||
|
|
||||||
def pytest_xdist_newgateway(gateway):
|
def pytest_xdist_newgateway(gateway):
|
||||||
""" called on new raw gateway creation. """
|
"""called on new raw gateway creation."""
|
||||||
|
|
||||||
|
|
||||||
def pytest_xdist_rsyncstart(source, gateways):
|
def pytest_xdist_rsyncstart(source, gateways):
|
||||||
""" called before rsyncing a directory to remote gateways takes place. """
|
"""called before rsyncing a directory to remote gateways takes place."""
|
||||||
|
|
||||||
|
|
||||||
def pytest_xdist_rsyncfinish(source, gateways):
|
def pytest_xdist_rsyncfinish(source, gateways):
|
||||||
""" called after rsyncing a directory to remote gateways takes place. """
|
"""called after rsyncing a directory to remote gateways takes place."""
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.firstresult
|
@pytest.mark.firstresult
|
||||||
def pytest_xdist_getremotemodule():
|
def pytest_xdist_getremotemodule():
|
||||||
""" called when creating remote node"""
|
"""called when creating remote node"""
|
||||||
|
|
||||||
|
|
||||||
def pytest_configure_node(node):
|
def pytest_configure_node(node):
|
||||||
""" configure node information before it gets instantiated. """
|
"""configure node information before it gets instantiated."""
|
||||||
|
|
||||||
|
|
||||||
def pytest_testnodeready(node):
|
def pytest_testnodeready(node):
|
||||||
""" Test Node is ready to operate. """
|
"""Test Node is ready to operate."""
|
||||||
|
|
||||||
|
|
||||||
def pytest_testnodedown(node, error):
|
def pytest_testnodedown(node, error):
|
||||||
""" Test Node is down. """
|
"""Test Node is down."""
|
||||||
|
|
||||||
|
|
||||||
def pytest_xdist_node_collection_finished(node, ids):
|
def pytest_xdist_node_collection_finished(node, ids):
|
||||||
@@ -53,7 +53,7 @@ def pytest_xdist_node_collection_finished(node, ids):
|
|||||||
|
|
||||||
@pytest.mark.firstresult
|
@pytest.mark.firstresult
|
||||||
def pytest_xdist_make_scheduler(config, log):
|
def pytest_xdist_make_scheduler(config, log):
|
||||||
""" return a node scheduler implementation """
|
"""return a node scheduler implementation"""
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.firstresult
|
@pytest.mark.firstresult
|
||||||
|
|||||||
@@ -293,7 +293,7 @@ class WorkerController:
|
|||||||
self._shutdown_sent = True
|
self._shutdown_sent = True
|
||||||
|
|
||||||
def sendcommand(self, name, **kwargs):
|
def sendcommand(self, name, **kwargs):
|
||||||
""" send a named parametrized command to the other side. """
|
"""send a named parametrized command to the other side."""
|
||||||
self.log("sending command {}(**{})".format(name, kwargs))
|
self.log("sending command {}(**{})".format(name, kwargs))
|
||||||
self.channel.send((name, kwargs))
|
self.channel.send((name, kwargs))
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user