Ritesh Ghorse

Redis cache support for enrichment transform

6

This PR implements Redis caching support for `RequestResponseIO` and integrates it with [Enrichment transform](https://s.apache.org/enrichment-transform). It also enables the test for RRIO and Enrichment with [HTTP Mock API](https://github.com/apache/beam/tree/master/.test-infra/mock-apis). Part of #29787...

[Python] Log dependencies installed in submission environment

17

Saves the submission environment dependencies and stage it. Logs it along with the runtime dependencies. Fixes #28563 ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate...

[Feature Request]: Request Response IO for Python SDK

2

### What would you like to happen? Implement a request response IO to interact with REST APIs/GRPC in beam pipeline. This should be in parity with the Java implementaion tracked...

[Feature Request]: Enrichment Transform

2

### What would you like to happen? Implement a enrichment transform to enrich a PCollection by making a request to the external source. ### Issue Priority Priority: 2 (default /...

[Python] Upgrade mypy version to 1.7.1

2

Upgrades mypy version to 1.7.1. Some files are yet to done and added to ignore list with github issue in mypyi.ini. ------------------------ Thank you for your contribution! Follow this checklist...

[WIP] try new protobuf

3

**Please** add a meaningful description for your change here ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ]...

[Failing Test]: YAML integration tests are flaky as a result of failing to start expansion service

1

### What happened? Some of the yaml tests attached below are flaky. We can probably add a retry strategy to start the expansion service for these tests-  Latest run...

Change error reporting to Temporary while Creating Volume

2

When `CreateVolume` is called, the `csi-provisioner` expects either "final" or "temporary" errors. If we report final error when Filestore instance creation could be ongoing or it is already created, then...

Promote gcp-filestore-csi-driver v1.7.0 to k8s-prod

4

Image: [v1.7.0](https://pantheon.corp.google.com/gcr/images/k8s-staging-cloud-provider-gcp/global/gcp-filestore-csi-driver@sha256:4ab81e366446a9f55c978e07311574997d933e38000cf38194154eecbe9fd5b3/details?e=-13802955&mods=logs_tg_prod&project=k8s-staging-cloud-provider-gcp&supportedpurview=project&tab=info)

Verify test suite is failing on PRs

2

The error message is ``` pkg/releaselock/rpc.go:88:31: address format "%s:%s" does not work with IPv6 (passed to net.Dial at L90) ``` Example failure - [Link](https://prow.k8s.io/view/gs/kubernetes-ci-logs/pr-logs/pull/kubernetes-sigs_gcp-filestore-csi-driver/905/pull-gcp-filestore-csi-driver-verify/1979090876411940864)