[
https://issues.apache.org/jira/browse/BEAM-758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15736667#comment-15736667
]
Luke Cwik commented on BEAM-758:
I would suggest building this into new DoFn, add an annotation called
[
https://issues.apache.org/jira/browse/BEAM-758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15736625#comment-15736625
]
Daniel Halperin commented on BEAM-758:
--
If plausible, I'd also like to not need to expose this in the
[
https://issues.apache.org/jira/browse/BEAM-758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15736622#comment-15736622
]
Daniel Halperin commented on BEAM-758:
--
This indeed seems like a step along the right track.
We also
[
https://issues.apache.org/jira/browse/BEAM-758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15736212#comment-15736212
]
Sam McVeety commented on BEAM-758:
--
Here's a sketch of how this could work, with default behavior that
[
https://issues.apache.org/jira/browse/BEAM-758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15736167#comment-15736167
]
Davor Bonaci commented on BEAM-758:
---
[~s...@google.com] volunteered to take this task. Great!
> Per-step,
[
https://issues.apache.org/jira/browse/BEAM-758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15735995#comment-15735995
]
Sam McVeety commented on BEAM-758:
--
The runner-contingent option seems viable. Something like:
[
https://issues.apache.org/jira/browse/BEAM-758?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15582798#comment-15582798
]
Luke Cwik commented on BEAM-758:
Several runners have the concept of a job or pipeline id, using a stable
