@require_cluster(1, require_container_agent=True)
    def test_current(self, cluster):
        """
        The current container endpoint includes a currently running container.
        """
        creating = self._create_container(
            cluster, SCRIPTS.child(b"hellohttp.py")
        )

        def created(data):
            data[u"running"] = True

            def in_current():
                current = cluster.current_containers()
                current.addCallback(lambda result: data in result)
                return current
            return loop_until(reactor, in_current)
        creating.addCallback(created)
        return creating
dataset/ETHPy150Open ClusterHQ/flocker/flocker/acceptance/obsolete/test_containers.py/ContainerAPITests.test_current/original