Searched refs:_get_pipeline (Results 1 – 1 of 1) sorted by relevance
3337 def _get_pipeline(self): member in TestSharding3354 sharded_dp = self._get_pipeline().sharding_filter()3362 sharded_dp = self._get_pipeline().sharding_filter()3465 dp = self._get_pipeline()3493 dp0 = self._get_pipeline()3496 dp0 = self._get_pipeline().sharding_filter()3503 dp0 = self._get_pipeline()3506 dp0 = self._get_pipeline()