Allow timeout for async DoFn

[RustedBones]

No description provided.

[codecov]

Codecov Report

All modified and coverable lines are covered by tests ✅

Comparison is base (9f4603e) 63.05% compared to head (862b054) 62.56%.
Report is 1 commits behind head on main.

Additional details and impacted files

@@            Coverage Diff             @@
##             main    #5201      +/-   ##
==========================================
- Coverage   63.05%   62.56%   -0.50%     
==========================================
  Files         300      301       +1     
  Lines       10947    10807     -140     
  Branches      740      764      +24     
==========================================
- Hits         6903     6761     -142     
- Misses       4044     4046       +2     

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

[kellen]

Is this a speculated fix to the hanging pipelines?

[RustedBones]

Yes. One user reported that setting the timeout will at least retry the bundle instead of hanging forever.
The root cause for the future that never completes is however still unknown.

It would be also nice to set the timeout as an option for the GrpcDoFn

[RustedBones]

MoreExecutors.directExecutor() doc says callback may not be executed if the exception terminates the executing thread

In other cases, no code will catch the exception, and it may terminate whichever thread happens to trigger the execution.

I've changed to use another executor that also completes the future when if it refuses to execute the callback. This is the strategy used by guava when transforming futures.

[RustedBones]

Closing for now in favor of #5209 will reconsider if not solved