code: def async_or_eager(self, **options):
          
          args = options.pop("args", None)
          kwargs = options.pop("kwargs", None)
          possible_broker_errors = self._get_possible_broker_errors_tuple()
          try:
              return self.apply_async(args, kwargs, **options)
          except possible_broker_errors:
              return self.apply(args, kwargs, **options)
docs: Attempt to call self.apply_async, or if that fails because of a problem
          with the broker, run the task eagerly and return an EagerResult.