[ 
https://issues.apache.org/jira/browse/BEAM-14251?focusedWorklogId=758094&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-758094
 ]

ASF GitHub Bot logged work on BEAM-14251:
-----------------------------------------

                Author: ASF GitHub Bot
            Created on: 18/Apr/22 19:39
            Start Date: 18/Apr/22 19:39
    Worklog Time Spent: 10m 
      Work Description: ihji commented on code in PR #17280:
URL: https://github.com/apache/beam/pull/17280#discussion_r852360778


##########
sdks/python/apache_beam/transforms/external.py:
##########
@@ -433,6 +434,9 @@ def __init__(self, urn, payload, expansion_service=None):
     self._inputs = {}  # type: Dict[str, pvalue.PCollection]
     self._outputs = {}  # type: Dict[str, pvalue.PCollection]
 
+  def with_output_types(self, *args, **kwargs):

Review Comment:
   Without it, the default implementation only allows a single argument.





Issue Time Tracking
-------------------

    Worklog Id:     (was: 758094)
    Time Spent: 3.5h  (was: 3h 20m)

> add output_coder_override to ExpansionRequest
> ---------------------------------------------
>
>                 Key: BEAM-14251
>                 URL: https://issues.apache.org/jira/browse/BEAM-14251
>             Project: Beam
>          Issue Type: Improvement
>          Components: cross-language
>            Reporter: Heejong Lee
>            Assignee: Heejong Lee
>            Priority: P2
>          Time Spent: 3.5h
>  Remaining Estimate: 0h
>
> add output_coder_override to ExpansionRequest



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to