Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(29)  |  Call(29)  |  Derive(0)  |  Import(0)

src/z/a/zato-HEAD/code/zato-common/test/zato/common/pubsub/test_api_impl.py   zato(Download)
 
        self.assertEquals(len(msg_metadata_dict), 1)
        self.assertTrue(ctx.msg.msg_id in msg_metadata_dict)
 
        msg_metadata = loads(msg_metadata_dict[ctx.msg.msg_id])
        expire_at_utc = parse(msg_metadata['expire_at_utc'])
 
        self.assertTrue(creation_time_utc < now, 'creation_time_utc:`{}` is not less than now:`{}`'.format(creation_time_utc, now))
        self.assertTrue(expire_at_utc > now, 'creation_time_utc:`{}` is not greater than now:`{}`'.format(expire_at_utc, now))
 
        self.assertEquals(len(last_pub_time), 1)
        last_pub_time = parse(last_pub_time[topic.name])
        self.assertTrue(last_pub_time < now, 'last_pub_time:`{}` is not less than now:`{}`'.format(last_pub_time, now))
 
        # ########################################################################################################################
        self.assertEquals(len(msg_expire_at), 1)
        msg_expire_at = parse(msg_expire_at[ctx.msg.msg_id])
        self.assertTrue(msg_expire_at > now, 'msg_expire_at:`{}` is not greater than now:`{}`'.format(msg_expire_at, now))
 
        # ########################################################################################################################

src/z/a/zato-HEAD/code/zato-common/test/zato/common/pubsub/test_full_path.py   zato(Download)
            if attr.startswith('LUA'):
                value = getattr(ps, attr)
                self.assertTrue(value in ps.lua_programs, value)
 
        topic_cust_new = Topic('/cust/new')
        eq_(len(ps.prod_to_topic), 2)
 
        self.assertTrue(client_id_crm.id in ps.prod_to_topic)
        self.assertTrue(client_id_billing.id in ps.prod_to_topic)
        self.assertTrue(client_id_erp.id not in ps.prod_to_topic)
 
        self.assertTrue(isinstance(ps.prod_to_topic[client_id_crm.id], set))