@defer.inlineCallbacks
        def statustest_status_updated(self):
            unique_status = uuid.uuid4().hex
            generate_override = ['-O', 'pipelines.generate-status:[{eval-lambda: {output_path: status, lambda: "baton: \'%s\'"}}]'%unique_status]

            yield utils.getProcessOutput('piped', ['-nc', 'twitter.yaml'] + self.oauth_override + generate_override, env=os.environ)

            # give twitter a second to propagate our updated status
            yield util.wait(1)

            api = tweepy.API()
            user = api.get_user(self.auth['username'])
            user = api.get_user(self.auth['username'])
            self.assertEquals(user.status.text, unique_status)
dataset/ETHPy150Open foundit/Piped/doc/tutorials/twitter/4_processor/twitter_tutorial/test_processors.py/TestTwitterProcessor.TestTwitter.statustest_status_updated/original