()
| 17 | |
| 18 | |
| 19 | def test_push_with_batch(): |
| 20 | push_source = PushSource( |
| 21 | name="test", |
| 22 | batch_source=BigQuerySource(table="test.test"), |
| 23 | ) |
| 24 | push_source_proto = push_source.to_proto() |
| 25 | assert push_source_proto.HasField("batch_source") |
| 26 | |
| 27 | push_source_unproto = PushSource.from_proto(push_source_proto) |
| 28 | |
| 29 | assert push_source.name == push_source_unproto.name |
| 30 | assert push_source.batch_source.name == push_source_unproto.batch_source.name |
| 31 | |
| 32 | |
| 33 | def test_push_source_without_batch_source(): |
nothing calls this directly
no test coverage detected