Ensure that assert_that takes a PCollection as its first argument.
Ensure that assert_that takes a PCollection as its first argument.

This can avoid (silent) error such as

    with test_pipeline.TestPipeline() as p:
      bad_value = "Create0" >> beam.Create([1])  # Note missing "p | "
      beam_util.assert_that(bad_value, beam_util.equal_to([0]))

chamikaramj/beam,rangadi/beam,eljefe6a/incubator-beam,amitsela/incubator-beam,sammcveety/incubator-beam,jbonofre/incubator-beam,tgroh/beam,amarouni/incubator-beam,RyanSkraba/beam,charlesccychen/beam,RyanSkraba/beam,rangadi/beam,yk5/beam,jbonofre/incubator-beam,charlesccychen/beam,charlesccychen/beam,dhalperi/incubator-beam,apache/beam,charlesccychen/incubator-beam,rangadi/beam,xsm110/Apache-Beam,tgroh/beam,charlesccychen/beam,charlesccychen/incubator-beam,staslev/beam,wangyum/beam,lukecwik/incubator-beam,chamikaramj/beam,lukecwik/incubator-beam,mxm/incubator-beam,markflyhigh/incubator-beam,robertwb/incubator-beam,robertwb/incubator-beam,rangadi/beam,vikkyrk/incubator-beam,robertwb/incubator-beam,wtanaka/beam,chamikaramj/beam,rangadi/beam,chamikaramj/beam,eljefe6a/incubator-beam,staslev/beam,wtanaka/beam,robertwb/incubator-beam,jbonofre/beam,sammcveety/incubator-beam,dhalperi/beam,charlesccychen/beam,lukecwik/incubator-beam,RyanSkraba/beam,iemejia/incubator-beam,manuzhang/incubator-beam,RyanSkraba/beam,sammcveety/incubator-beam,apache/beam,manuzhang/beam,robertwb/incubator-beam,robertwb/incubator-beam,xsm110/Apache-Beam,lukecwik/incubator-beam,apache/beam,robertwb/incubator-beam,jbonofre/beam,markflyhigh/incubator-beam,manuzhang/incubator-beam,eljefe6a/incubator-beam,tgroh/beam,lukecwik/incubator-beam,staslev/incubator-beam,robertwb/incubator-beam,yk5/beam,rangadi/beam,amitsela/beam,chamikaramj/beam,amarouni/incubator-beam,chamikaramj/beam,rangadi/incubator-beam,chamikaramj/beam,apache/beam,RyanSkraba/beam,rangadi/incubator-beam,amitsela/beam,lukecwik/incubator-beam,robertwb/incubator-beam,apache/beam,amitsela/beam,lukecwik/incubator-beam,jbonofre/beam,apache/beam,amitsela/incubator-beam,lukecwik/incubator-beam,tgroh/beam,manuzhang/beam,wangyum/beam,lukecwik/incubator-beam,lukecwik/incubator-beam,apache/beam,yk5/beam,RyanSkraba/beam,apache/beam,RyanSkraba/beam,markflyhigh/incubator-beam,chamikaramj/beam,chamikaramj/beam,staslev/incubator-beam,manuzhang/beam,jbonofre/beam,markflyhigh/incubator-beam,robertwb/incubator-beam,staslev/beam,iemejia/incubator-beam,rangadi/incubator-beam,charlesccychen/beam,tgroh/incubator-beam,peihe/incubator-beam,xsm110/Apache-Beam,markflyhigh/incubator-beam,dhalperi/beam,dhalperi/beam,wangyum/beam,chamikaramj/beam,rangadi/beam,peihe/incubator-beam,mxm/incubator-beam,vikkyrk/incubator-beam,wangyum/beam,charlesccychen/incubator-beam,apache/beam,vikkyrk/incubator-beam,markflyhigh/incubator-beam,peihe/incubator-beam,dhalperi/incubator-beam,tgroh/incubator-beam,apache/beam,wtanaka/beam,markflyhigh/incubator-beam,apache/beam,charlesccychen/beam