code: def _handle_tag_schedule_return(self, tag, data):
          '''
          Handle a _schedule_return event
          '''
          # reporting current connection with master
          if data['schedule'].startswith(master_event(type='alive', master='')):
              if data['return']:
                  log.debug(
                      'Connected to master %s',
                      data['schedule'].split(master_event(type='alive', master=''))[1]
                  )
          self._return_pub(data, ret_cmd='_return', sync=Falsef _handle_tag_schedule_return(self, tag, data):
          '''
          Handle a _schedule_return event
          '''
          # reporting current connection with master
          if data['schedule'].startswith(master_event(type='alive', master='')):
              if data['return']:
                  log.debug(
                      'Connected to master %s',
                      data['schedule'].split(master_event(type='alive', master=''))[1]
                  )
          self._return_pub(data, ret_cmd='_return', sync=False)
docs: Handle a _schedule_return event