original_docstring: Creates or updates a data flow.
  
          :param data_flow_name: The data flow name.
          :type data_flow_name: str
          :param properties: Data flow properties.
          :type properties: ~azure.synapse.artifacts.models.DataFlow
          :param if_match: ETag of the data flow entity. Should only be specified for update, for which
           it should match existing entity or can be * for unconditional update.
          :type if_match: str
          :keyword callable cls: A custom type or function that will be passed the direct response
          :keyword str continuation_token: A continuation token to restart a poller from a saved state.
          :keyword polling: Pass in True if you'd like the AsyncLROBasePolling polling method,
           False for no polling, or your own initialized polling object for a personal polling strategy.
          :paramtype polling: bool or ~azure.core.polling.AsyncPollingMethod
          :keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present.
          :return: An instance of AsyncLROPoller that returns either DataFlowResource or the result of cls(response)
          :rtype: ~azure.core.polling.AsyncLROPoller[~azure.synapse.artifacts.models.DataFlowResource]
          :raises ~azure.core.exceptions.HttpResponseError:
          
docstring: Creates or updates a data flow.
docstring_tokens: Creates or updates a data flow .
code: async def begin_create_or_update_data_flow(
          self,
          data_flow_name: str,
          properties: "_models.DataFlow",
          if_match: Optional[str] = None,
          **kwargs
      ) -> AsyncLROPoller["_models.DataFlowResource"]:
          """Creates or updates a data flow.
  
          :param data_flow_name: The data flow name.
          :type data_flow_name: str
          :param properties: Data flow properties.
          :type properties: ~azure.synapse.artifacts.models.DataFlow
          :param if_match: ETag of the data flow entity. Should only be specified for update, for which
           it should match existing entity or can be * for unconditional update.
          :type if_match: str
          :keyword callable cls: A custom type or function that will be passed the direct response
          :keyword str continuation_token: A continuation token to restart a poller from a saved state.
          :keyword polling: Pass in True if you'd like the AsyncLROBasePolling polling method,
           False for no polling, or your own initialized polling object for a personal polling strategy.
          :paramtype polling: bool or ~azure.core.polling.AsyncPollingMethod
          :keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present.
          :return: An instance of AsyncLROPoller that returns either DataFlowResource or the result of cls(response)
          :rtype: ~azure.core.polling.AsyncLROPoller[~azure.synapse.artifacts.models.DataFlowResource]
          :raises ~azure.core.exceptions.HttpResponseError:
          """
          polling = kwargs.pop('polling', False)  # type: Union[bool, AsyncPollingMethod]
          cls = kwargs.pop('cls', None)  # type: ClsType["_models.DataFlowResource"]
          lro_delay = kwargs.pop(
              'polling_interval',
              self._config.polling_interval
          )
          cont_token = kwargs.pop('continuation_token', None)  # type: Optional[str]
          if cont_token is None:
              raw_result = await self._create_or_update_data_flow_initial(
                  data_flow_name=data_flow_name,
                  properties=properties,
                  if_match=if_match,
                  cls=lambda x,y,z: x,
                  **kwargs
              )
  
          kwargs.pop('error_map', None)
          kwargs.pop('content_type', None)
  
          def get_long_running_output(pipeline_response):
              deserialized = self._deserialize('DataFlowResource', pipeline_response)
  
              if cls:
                  return cls(pipeline_response, deserialized, {})
              return deserialized
  
          path_format_arguments = {
              'endpoint': self._serialize.url("self._config.endpoint", self._config.endpoint, 'str', skip_quote=True),
              'dataFlowName': self._serialize.url("data_flow_name", data_flow_name, 'str', max_length=260, min_length=1, pattern=r'^[A-Za-z0-9_][^<>*#.%&:\\+?/]*$'),
          }
  
          if polling is True: polling_method = AsyncLROBasePolling(lro_delay, path_format_arguments=path_format_arguments,  **kwargs)
          elif polling is False: polling_method = AsyncNoPolling()
          else: polling_method = polling
          if cont_token:
              return AsyncLROPoller.from_continuation_token(
                  polling_method=polling_method,
                  continuation_token=cont_token,
                  client=self._client,
                  deserialization_callback=get_long_running_output
              )
          else:
              return AsyncLROPoller(self._client, raw_result, get_long_running_output, polling_method)
code_tokens: async def begin_create_or_update_data_flow ( self , data_flow_name : str , properties : "_models.DataFlow" , if_match : Optional [ str ] = None , ** kwargs ) -> AsyncLROPoller [ "_models.DataFlowResource" ] : polling = kwargs . pop ( 'polling' , False ) cls = kwargs . pop ( 'cls' , None ) lro_delay = kwargs . pop ( 'polling_interval' , self . _config . polling_interval ) cont_token = kwargs . pop ( 'continuation_token' , None ) if cont_token is None : raw_result = await self . _create_or_update_data_flow_initial ( data_flow_name = data_flow_name , properties = properties , if_match = if_match , cls = lambda x , y , z : x , ** kwargs ) kwargs . pop ( 'error_map' , None ) kwargs . pop ( 'content_type' , None ) def get_long_running_output ( pipeline_response ) : deserialized = self . _deserialize ( 'DataFlowResource' , pipeline_response ) if cls : return cls ( pipeline_response , deserialized , { } ) return deserialized path_format_arguments = { 'endpoint' : self . _serialize . url ( "self._config.endpoint" , self . _config . endpoint , 'str' , skip_quote = True ) , 'dataFlowName' : self . _serialize . url ( "data_flow_name" , data_flow_name , 'str' , max_length = 260 , min_length = 1 , pattern = r'^[A-Za-z0-9_][^<>*#.%&:\\+?/]*$' ) , } if polling is True : polling_method = AsyncLROBasePolling ( lro_delay , path_format_arguments = path_format_arguments , ** kwargs ) elif polling is False : polling_method = AsyncNoPolling ( ) else : polling_method = polling if cont_token : return AsyncLROPoller . from_continuation_token ( polling_method = polling_method , continuation_token = cont_token , client = self . _client , deserialization_callback = get_long_running_output ) else : return AsyncLROPoller ( self . _client , raw_result , get_long_running_output , polling_method )
short_docstring: Creates or updates a data flow.
short_docstring_tokens: Creates or updates a data flow .
comment: """Creates or updates a data flow.
  
          :param data_flow_name: The data flow name.
          :type data_flow_name: str
          :param properties: Data flow properties.
          :type properties: ~azure.synapse.artifacts.models.DataFlow
          :param if_match: ETag of the data flow entity. Should only be specified for update, for which
           it should match existing entity or can be * for unconditional update.
          :type if_match: str
          :keyword callable cls: A custom type or function that will be passed the direct response
          :keyword str continuation_token: A continuation token to restart a poller from a saved state.
          :keyword polling: Pass in True if you'd like the AsyncLROBasePolling polling method,
           False for no polling, or your own initialized polling object for a personal polling strategy.
          :paramtype polling: bool or ~azure.core.polling.AsyncPollingMethod
          :keyword int polling_interval: Default waiting time between two polls for LRO operations if no Retry-After header is present.
          :return: An instance of AsyncLROPoller that returns either DataFlowResource or the result of cls(response)
          :rtype: ~azure.core.polling.AsyncLROPoller[~azure.synapse.artifacts.models.DataFlowResource]
          :raises ~azure.core.exceptions.HttpResponseError:
          """$SEP$# type: Union[bool, AsyncPollingMethod]$SEP$# type: ClsType["_models.DataFlowResource"]$SEP$# type: Optional[str]