apache / apache/beam

Add exception handling to single message transforms in Python SDK

Open
#19,129 0 comments 0 reactions 0 assignees View on GitHub
core improvement P3 python
Dominant language
Java
Stars
8.7k
Forks
4.7k
Avg merge
1d 20h
Merged PRs (30d)
196

Description

Add methods to python SDK Map and FlatMap that allow users to specify expected exceptions and tuple tags to associate with the with collections of the successfully and unsuccessfully processed elements.

See discussion on dev list:

[https://lists.apache.org/thread.html/936ed2a5f2c01be066fd903abf70130625e0b8cf4028c11b89b8b23f@%3Cdev.beam.apache.org%3E](https://lists.apache.org/thread.html/936ed2a5f2c01be066fd903abf70130625e0b8cf4028c11b89b8b23f@%3Cdev.beam.apache.org%3E)

Imported from Jira [BEAM-5639](https://issues.apache.org/jira/browse/BEAM-5639). Original Jira may contain additional context.
Reported by: jeff.klukas@gmail.com.

Contributor guide

Open the contributing guide

Research direction

Start with the linked dev-list discussion and the imported Jira issue for the intended API and behavior, then locate the Python SDK implementations of Map and FlatMap. The work is done when both transforms accept expected exceptions and tuple tags for successfully and unsuccessfully processed elements, with behavior covered by appropriate tests.

Written by the indexing model from the issue text.

Assessment

Tech stack
python
Domain
data-engineering
Issue type
Feature
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Needs clarification
Newbie friendliness
35/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.