How to use wait_until_stopped method in Playwright Python

Best Python code snippet using playwright-python

traits_executor_tests.py

Source:traits_executor_tests.py

...119        with self.long_running_task(self.executor):120            self.assertEqual(self.executor.state, RUNNING)121            self.executor.stop()122            self.assertEqual(self.executor.state, STOPPING)123        self.wait_until_stopped(self.executor)124        self.assertEqual(self.executor.state, STOPPED)125        self.assertEqual(self.listener.states, [RUNNING, STOPPING, STOPPED])126    def test_stop_method_with_no_jobs(self):127        self.assertEqual(self.executor.state, RUNNING)128        self.executor.stop()129        self.wait_until_stopped(self.executor)130        self.assertEqual(self.executor.state, STOPPED)131        self.assertEqual(self.listener.states, [RUNNING, STOPPING, STOPPED])132    def test_stop_method_raises_unless_running(self):133        with self.long_running_task(self.executor):134            self.assertEqual(self.executor.state, RUNNING)135            self.executor.stop()136            # Raises if in STOPPING mode.137            self.assertEqual(self.executor.state, STOPPING)138            with self.assertRaises(RuntimeError):139                self.executor.stop()140        self.wait_until_stopped(self.executor)141        # Raises if in STOPPED mode.142        self.assertEqual(self.executor.state, STOPPED)143        with self.assertRaises(RuntimeError):144            self.executor.stop()145    def test_shutdown_when_already_stopping(self):146        with self.long_running_task(self.executor):147            self.assertEqual(self.executor.state, RUNNING)148            self.executor.stop()149        self.assertEqual(self.executor.state, STOPPING)150        self.executor.shutdown(timeout=SAFETY_TIMEOUT)151        self.assertEqual(self.executor.state, STOPPED)152    def test_shutdown_does_nothing_if_stopped(self):153        self.assertEqual(self.executor.state, RUNNING)154        self.executor.stop()155        self.wait_until_stopped(self.executor)156        self.assertEqual(self.executor.state, STOPPED)157        self.executor.shutdown(timeout=SAFETY_TIMEOUT)158        self.assertEqual(self.executor.state, STOPPED)159    def test_shutdown_cancels_running_futures(self):160        future = submit_call(self.executor, pow, 3, 5)161        self.executor.shutdown(timeout=SAFETY_TIMEOUT)162        self.assertEqual(future.state, CANCELLED)163        self.assertTrue(self.executor.stopped)164    def test_no_future_updates_after_shutdown(self):165        future = submit_call(self.executor, pow, 3, 5)166        self.executor.shutdown(timeout=SAFETY_TIMEOUT)167        self.assertEqual(future.state, CANCELLED)168        self.exercise_event_loop()169        self.assertEqual(future.state, CANCELLED)170    def test_shutdown_goes_through_stopping_state(self):171        self.executor.shutdown(timeout=SAFETY_TIMEOUT)172        self.assertEqual(173            self.listener.states,174            [RUNNING, STOPPING, STOPPED],175        )176    def test_shutdown_waits_for_background_tasks(self):177        starting = self._context.event()178        stopping = self._context.event()179        submit_call(self.executor, slow_call, starting, stopping)180        # Make sure background task has started, else it might be181        # cancelled altogether.182        self.assertTrue(starting.wait(timeout=SAFETY_TIMEOUT))183        self.executor.shutdown(timeout=SAFETY_TIMEOUT)184        self.assertTrue(stopping.is_set())185    def test_shutdown_timeout(self):186        start_time = time.monotonic()187        with self.long_running_task(self.executor):188            with self.assertRaisesRegex(RuntimeError, "1 tasks still running"):189                self.executor.shutdown(timeout=0.1)190        actual_timeout = time.monotonic() - start_time191        self.assertLess(actual_timeout, 1.0)192        self.assertEqual(self.executor.state, STOPPING)193        self.executor.shutdown(timeout=SAFETY_TIMEOUT)194        self.assertEqual(self.executor.state, STOPPED)195    def test_cant_submit_new_unless_running(self):196        with self.long_running_task(self.executor):197            self.executor.stop()198            self.assertEqual(self.executor.state, STOPPING)199            with self.assertRaises(RuntimeError):200                submit_call(self.executor, len, (1, 2, 3))201        self.wait_until_stopped(self.executor)202        self.assertEqual(self.executor.state, STOPPED)203        with self.assertRaises(RuntimeError):204            submit_call(self.executor, int)205    def test_stop_cancels_running_futures(self):206        with self.long_running_task(self.executor) as future:207            self.wait_for_state(future, EXECUTING)208            self.assertEqual(future.state, EXECUTING)209            self.executor.stop()210            self.assertEqual(future.state, CANCELLING)211        self.wait_until_done(future)212        self.assertEqual(future.state, CANCELLED)213        self.wait_until_stopped(self.executor)214        self.assertEqual(self.executor.state, STOPPED)215    def test_running(self):216        self.assertTrue(self.executor.running)217        with self.long_running_task(self.executor):218            self.assertTrue(self.executor.running)219            self.executor.stop()220            self.assertFalse(self.executor.running)221        self.wait_until_stopped(self.executor)222        self.assertFalse(self.executor.running)223    def test_stopped(self):224        self.assertFalse(self.executor.stopped)225        with self.long_running_task(self.executor):226            self.assertFalse(self.executor.stopped)227            self.executor.stop()228            self.assertFalse(self.executor.stopped)229        self.wait_until_stopped(self.executor)230        self.assertTrue(self.executor.stopped)231    def test_submit_call_method(self):232        with self.assertWarns(DeprecationWarning) as warning_info:233            future = self.executor.submit_call(234                test_call, "arg1", "arg2", kwd1="kwd1", kwd2="kwd2"235            )236        self.wait_until_done(future)237        self.assertEqual(238            future.result,239            (("arg1", "arg2"), {"kwd1": "kwd1", "kwd2": "kwd2"}),240        )241        _, _, this_module = __name__.rpartition(".")242        self.assertIn(this_module, warning_info.filename)243        self.assertIn(244            "submit_call method is deprecated",245            str(warning_info.warning),246        )247    def test_submit_iteration_method(self):248        with self.assertWarns(DeprecationWarning) as warning_info:249            future = self.executor.submit_iteration(250                test_iteration,251                "arg1",252                "arg2",253                kwd1="kwd1",254                kwd2="kwd2",255            )256        results = []257        future.observe(lambda event: results.append(event.new), "result_event")258        self.wait_until_done(future)259        self.assertEqual(260            results,261            [("arg1", "arg2"), {"kwd1": "kwd1", "kwd2": "kwd2"}],262        )263        _, _, this_module = __name__.rpartition(".")264        self.assertIn(this_module, warning_info.filename)265        self.assertIn(266            "submit_iteration method is deprecated",267            str(warning_info.warning),268        )269    def test_submit_progress_method(self):270        with self.assertWarns(DeprecationWarning) as warning_info:271            future = self.executor.submit_progress(272                test_progress,273                "arg1",274                "arg2",275                kwd1="kwd1",276                kwd2="kwd2",277            )278        self.wait_until_done(future)279        self.assertEqual(280            future.result,281            ("arg1", "arg2", "kwd1", "kwd2"),282        )283        _, _, this_module = __name__.rpartition(".")284        self.assertIn(this_module, warning_info.filename)285        self.assertIn(286            "submit_progress method is deprecated",287            str(warning_info.warning),288        )289    def test_states_consistent(self):290        # Triples (state, running, stopped).291        states = []292        def record_states(event=None):293            states.append(294                (295                    self.executor.state,296                    self.executor.running,297                    self.executor.stopped,298                )299            )300        self.executor.observe(record_states, "running")301        self.executor.observe(record_states, "stopped")302        self.executor.observe(record_states, "state")303        submit_call(self.executor, int)304        # Record states before, during, and after stopping.305        record_states()306        self.executor.stop()307        self.wait_until_stopped(self.executor)308        record_states()309        for state, running, stopped in states:310            self.assertEqual(running, state == RUNNING)311            self.assertEqual(stopped, state == STOPPED)312    def test_running_and_stopped_fired_only_once(self):313        submit_call(self.executor, int)314        self.executor.stop()315        self.wait_until_stopped(self.executor)316        self.assertEqual(self.listener.running_changes, [(True, False)])317        self.assertEqual(self.listener.stopped_changes, [(False, True)])318    def test_running_and_stopped_fired_only_once_no_futures(self):319        # Same as above but tests the case where the executor goes to STOPPED320        # state the moment that stop is called.321        self.executor.stop()322        self.wait_until_stopped(self.executor)323        self.assertEqual(self.listener.running_changes, [(True, False)])324        self.assertEqual(self.listener.stopped_changes, [(False, True)])325    def test_multiple_futures(self):326        futures = []327        for i in range(100):328            futures.append(submit_call(self.executor, str, i))329        listener = FuturesListener(futures=futures)330        # Wait for all futures to complete.331        self.run_until(332            listener, "all_done", lambda listener: listener.all_done333        )334        for i, future in enumerate(futures):335            self.assertEqual(future.result, str(i))336    def test_stop_with_multiple_futures(self):337        futures = []338        for i in range(100):339            futures.append(submit_call(self.executor, str, i))340        self.executor.stop()341        self.wait_until_stopped(self.executor)342        for future in futures:343            self.assertEqual(future.state, CANCELLED)344    def test_submit_from_background_thread(self):345        def target(executor, msg_queue):346            """347            Submit a simple callable to the given executor, and report348            the result of that submission to a queue.349            """350            try:351                future = submit_call(executor, pow, 2, 3)352            except BaseException as exc:353                msg_queue.put(("FAILED", exc))354            else:355                msg_queue.put(("DONE", future))356        msg_queue = queue.Queue()357        worker = threading.Thread(358            target=target, args=(self.executor, msg_queue)359        )360        worker.start()361        try:362            result_type, future_or_exc = msg_queue.get(timeout=SAFETY_TIMEOUT)363        finally:364            worker.join(timeout=SAFETY_TIMEOUT)365        self.assertEqual(result_type, "FAILED")366        self.assertIsInstance(future_or_exc, RuntimeError)367    # Helper methods and assertions ###########################################368    def wait_until_stopped(self, executor):369        """370        Wait for the executor to reach STOPPED state.371        """372        self.run_until(executor, "stopped", lambda executor: executor.stopped)373    def wait_until_done(self, future):374        self.run_until(future, "done", lambda future: future.done)375    def wait_for_state(self, future, state):376        self.run_until(future, "state", lambda future: future.state == state)377    @contextlib.contextmanager378    def long_running_task(self, executor, timeout=SAFETY_TIMEOUT):379        """380        Simulate a long-running task being submitted to the executor.381        This context manager waits for the task to start executing before382        yielding the future associated to that task. The task will be...

study_vm_service.py

Source:study_vm_service.py

...89        if status not in ALLOWED_STATUSES:90            raise InvalidEc2Status(status)91        study.status = status92        study.save()93def wait_until_stopped(instance, study):94    try:95        """96        Waits until this Instance is stopped. This method calls EC2.Waiter.instance_stopped.wait() which polls.97        EC2.Client.describe_instances() every 15 seconds until a successful state is reached.98        An error is returned after 40 failed checks.99        https://boto3.amazonaws.com/v1/documentation/api/latest/reference/services/ec2.html#EC2.Instance.wait_until_stopped100        """101        instance.wait_until_stopped()102        update_study_state(study, Study.VM_STOPPED)103    except Exception as e:104        logger.exception("Error trying to wait until instance stopped", e)105        update_study_state(study, Study.ST_ERROR)106def get_and_update_study_instance(boto3_client, study, status_filter):107    """108    get the study instance, and update the database accordingly to the VM status109    :param boto3_client: boto3 client with access to the study instance110    :param study: Study Django model111    :param status_filter: A list of ec2 instance statuses to filter by112    :return: aws ec2 instance object113    """114    execution_token = study.execution.execution_user.email.split("@")[0]115    instance = get_instance(boto3_client, execution_token, status_filter)...

robotiq_2f_gripper_ctrl.py

Source:robotiq_2f_gripper_ctrl.py

...49    # in mA50    def get_current(self):51        return self.cur_status.gCU * 0.152    # if timeout is negative, wait forever53    def wait_until_stopped(self, timeout=-1):54        r = rospy.Rate(30)55        start_time = rospy.get_time()56        while not rospy.is_shutdown():57            if (timeout >= 0. and rospy.get_time() - start_time > timeout) or self.is_reset():58                return False59            if self.is_stopped():60                return True61            r.sleep()62        return False63    def wait_until_moving(self, timeout=-1):64        r = rospy.Rate(30)65        start_time = rospy.get_time()66        while not rospy.is_shutdown():67            if (timeout >= 0. and rospy.get_time() - start_time > timeout) or self.is_reset():68                return False69            if not self.is_stopped():70                return True71            r.sleep()72        return False73    def reset(self):74        cmd = outputMsg()75        cmd.rACT = 076        self.cmd_pub.publish(cmd)77    def activate(self, timeout=-1):78        cmd = outputMsg()79        cmd.rACT = 180        cmd.rGTO = 181        cmd.rPR = 082        cmd.rSP = 25583        cmd.rFR = 15084        self.cmd_pub.publish(cmd)85        r = rospy.Rate(30)86        start_time = rospy.get_time()87        while not rospy.is_shutdown():88            if timeout >= 0. and rospy.get_time() - start_time > timeout:89                return False90            if self.is_ready():91                return True92            r.sleep()93        return False94    def auto_release(self):95        cmd = outputMsg()96        cmd.rACT = 197        cmd.rATR = 198        self.cmd_pub.publish(cmd)99    ##100    # Goto position with desired force and velocity101    # @param pos Gripper width in meters. [0, 0.087]102    # @param vel Gripper speed in m/s. [0.013, 0.100]103    # @param force Gripper force in N. [30, 100] (not precise)104    def goto(self, pos, vel, force, block=False, timeout=-1):105        cmd = outputMsg()106        cmd.rACT = 1107        cmd.rGTO = 1108        cmd.rPR = int(np.clip((13.-230.)/0.087 * pos + 230., 0, 255))109        cmd.rSP = int(np.clip(255./(0.1-0.013) * (vel-0.013), 0, 255))110        cmd.rFR = int(np.clip(255./(100.-30.) * (force-30.), 0, 255))111        self.cmd_pub.publish(cmd)112        rospy.sleep(0.1)113        if block:114            if not self.wait_until_moving(timeout):115                return False116            return self.wait_until_stopped(timeout)117        return True118    def stop(self, block=False, timeout=-1):119        cmd = outputMsg()120        cmd.rACT = 1121        cmd.rGTO = 0122        self.cmd_pub.publish(cmd)123        rospy.sleep(0.1)124        if block:125            return self.wait_until_stopped(timeout)126        return True127    def open(self, vel=0.1, force=100, block=False, timeout=-1):128        if self.is_opened():129            return True130        return self.goto(1.0, vel, force, block=block, timeout=timeout)131    def close(self, vel=0.1, force=100, block=False, timeout=-1):132        if self.is_closed():133            return True134        return self.goto(-1.0, vel, force, block=block, timeout=timeout)135def main():136    rospy.init_node("robotiq_2f_gripper_ctrl_test")137    gripper = RobotiqCGripper()138    gripper.wait_for_connection()139    if gripper.is_reset():...

backend_manager_test.py

Source:backend_manager_test.py

...60        self.mgr.start()61        await self.mgr.wait_until_running()62        self.assertTrue(self.mgr.is_running)63        self.mgr.stop()64        await self.mgr.wait_until_stopped()65        self.assertFalse(self.mgr.is_running)66    async def test_start_fails(self):67        self.backend.exception_in_start = True68        self.mgr.start()69        with self.assertRaises(RuntimeError):70            await self.mgr.wait_until_running()71        self.assertFalse(self.mgr.is_running)72    async def test_stop_fails(self):73        self.backend.exception_in_stop = True74        self.mgr.start()75        await self.mgr.wait_until_running()76        self.mgr.stop()77        with self.assertRaises(RuntimeError):78            await self.mgr.wait_until_stopped()79    async def test_crashed(self):80        self.mgr.start()81        await self.mgr.wait_until_running()82        self.mgr.crashed()83        await self.backend.is_stopped.wait()84    async def test_stop_crashed(self):85        self.mgr.start()86        await self.mgr.wait_until_running()87        self.mgr.crashed()88        self.mgr.stop()89        await self.mgr.wait_until_stopped()90    async def test_restart(self):91        self.backend.num_restarts = 192        self.mgr.start()93        await self.mgr.wait_until_running()94        self.mgr.crashed()95        await self.backend.is_restarted.wait()96        self.mgr.stop()97        await self.mgr.wait_until_stopped()98    async def test_crash_and_stop_fails(self):99        error_handler_called = asyncio.Event(loop=self.loop)100        def error_handler(event_loop, context):101            error_handler_called.set()102        self.loop.set_exception_handler(error_handler)103        self.backend.exception_in_stop = True104        self.mgr.start()105        await self.mgr.wait_until_running()106        self.mgr.crashed()...

Playwright tutorial

LambdaTest’s Playwright tutorial will give you a broader idea about the Playwright automation framework, its unique features, and use cases with examples to exceed your understanding of Playwright testing. This tutorial will give A to Z guidance, from installing the Playwright framework to some best practices and advanced concepts.

Chapters:

What is Playwright : Playwright is comparatively new but has gained good popularity. Get to know some history of the Playwright with some interesting facts connected with it.
How To Install Playwright : Learn in detail about what basic configuration and dependencies are required for installing Playwright and run a test. Get a step-by-step direction for installing the Playwright automation framework.
Playwright Futuristic Features: Launched in 2020, Playwright gained huge popularity quickly because of some obliging features such as Playwright Test Generator and Inspector, Playwright Reporter, Playwright auto-waiting mechanism and etc. Read up on those features to master Playwright testing.
What is Component Testing: Component testing in Playwright is a unique feature that allows a tester to test a single component of a web application without integrating them with other elements. Learn how to perform Component testing on the Playwright automation framework.
Inputs And Buttons In Playwright: Every website has Input boxes and buttons; learn about testing inputs and buttons with different scenarios and examples.
Functions and Selectors in Playwright: Learn how to launch the Chromium browser with Playwright. Also, gain a better understanding of some important functions like “BrowserContext,” which allows you to run multiple browser sessions, and “newPage” which interacts with a page.
Handling Alerts and Dropdowns in Playwright : Playwright interact with different types of alerts and pop-ups, such as simple, confirmation, and prompt, and different types of dropdowns, such as single selector and multi-selector get your hands-on with handling alerts and dropdown in Playright testing.
Playwright vs Puppeteer: Get to know about the difference between two testing frameworks and how they are different than one another, which browsers they support, and what features they provide.
Run Playwright Tests on LambdaTest: Playwright testing with LambdaTest leverages test performance to the utmost. You can run multiple Playwright tests in Parallel with the LammbdaTest test cloud. Get a step-by-step guide to run your Playwright test on the LambdaTest platform.
Playwright Python Tutorial: Playwright automation framework support all major languages such as Python, JavaScript, TypeScript, .NET and etc. However, there are various advantages to Python end-to-end testing with Playwright because of its versatile utility. Get the hang of Playwright python testing with this chapter.
Playwright End To End Testing Tutorial: Get your hands on with Playwright end-to-end testing and learn to use some exciting features such as TraceViewer, Debugging, Networking, Component testing, Visual testing, and many more.
Playwright Video Tutorial: Watch the video tutorials on Playwright testing from experts and get a consecutive in-depth explanation of Playwright automation testing.