File tree Expand file tree Collapse file tree
runners/prism/internal/engine Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -433,7 +433,7 @@ func (c *DataChannel) read(ctx context.Context) {
433433 // for all transforms in an instruction before the instruction even begun. However, we can't
434434 // know this until we received the Control instruction which knows how many transforms for which
435435 // we need to receive data. So we check the cache directly every so often and evict closed
436- // readers. We will never recieve data for these instructions again.
436+ // readers. We will never receive data for these instructions again.
437437 for instID , r := range cache {
438438 if r .Closed () {
439439 delete (cache , instID )
Original file line number Diff line number Diff line change @@ -299,7 +299,7 @@ func (tsi *testStreamImpl) initHandler(id string) {
299299 }
300300}
301301
302- // TagsToPCollections recieves the map of local output tags to global pcollection ids.
302+ // TagsToPCollections receives the map of local output tags to global pcollection ids.
303303func (tsi * testStreamImpl ) TagsToPCollections (tagToPcol map [string ]string ) {
304304 tsi .em .testStreamHandler .TagsToPCollections (tagToPcol )
305305}
You can’t perform that action at this time.
0 commit comments