B |?Xc' @sdZddlZeddZeddZejddd d Zejddd d Zejd dddZeddZeddZ eddZ eddZ ejd dddZ ejd dddZ ejd dddZdS)a xdist hooks. Additionally, pytest-xdist will also decorate a few other hooks with the worker instance that executed the hook originally: ``pytest_runtest_logreport``: ``rep`` parameter has a ``node`` attribute. You can use this hooks just as you would use normal pytest hooks, but some care must be taken in plugins in case ``xdist`` is not installed. Please see: http://pytest.org/en/latest/writing_plugins.html#optionally-using-hooks-from-3rd-party-plugins NcCsdS)z(called before any remote node is set up.N)configZspecsrr-lib/python3.7/site-packages/xdist/newhooks.pypytest_xdist_setupnodessrcCsdS)z#called on new raw gateway creation.Nr)Zgatewayrrrpytest_xdist_newgatewaysrzCrsync feature is deprecated and will be removed in pytest-xdist 4.0)Z warn_on_implcCsdS)zBcalled before rsyncing a directory to remote gateways takes place.Nr)sourcegatewaysrrrpytest_xdist_rsyncstartsr cCsdS)zAcalled after rsyncing a directory to remote gateways takes place.Nr)rrrrrpytest_xdist_rsyncfinish"sr T)Z firstresultcCsdS)z called when creating remote nodeNrrrrrpytest_xdist_getremotemodule)sr cCsdS)z7configure node information before it gets instantiated.Nr)noderrrpytest_configure_node.sr cCsdS)zTest Node is ready to operate.Nr)r rrrpytest_testnodeready3srcCsdS)zTest Node is down.Nr)r errorrrrpytest_testnodedown8srcCsdS)zEcalled by the controller node when a worker node finishes collecting.Nr)r Zidsrrr%pytest_xdist_node_collection_finished=srcCsdS)z&return a node scheduler implementationNr)rlogrrrpytest_xdist_make_schedulerBsrcCsdS)z Return the number of workers to spawn when ``--numprocesses=auto`` is given in the command-line. .. versionadded:: 2.1 Nr)rrrrpytest_xdist_auto_num_workersGsrcCsdS)a Handle a crashitem, modifying the report if necessary. The scheduler is provided as a parameter to reschedule the test if desired with `sched.mark_test_pending`. def pytest_handlecrashitem(crashitem, report, sched): if should_rerun(crashitem): sched.mark_test_pending(crashitem) report.outcome = "rerun" .. versionadded:: 2.2.1 Nr)Z crashitemZreportZschedrrrpytest_handlecrashitemQsr)__doc__ZpytestZhookspecrrr r r r rrrrrrrrrr s