code: async def start_store(app, url, workers=0, **kw):
      '''Equivalent to :func:`.create_store` for most cases excepts when the
      ``url`` is for a pulsar store not yet started.
      In this case, a :class:`.PulsarDS` is started.
      '''
      store = create_store(url, **kw)
      if store.name == 'pulsar':
          client = store.client()
          try:
              await client.ping()
          except ConnectionRefusedError:
              host = localhost(store._host)
              if not host:
                  raise
              cfg = await send('arbiter', 'run', start_pulsar_ds,
                               host, workers)
              store._host = cfg.addresses[0]
              dsn = store.buildurl()
              store = create_store(dsn, **kw)
      app.cfg.set('data_store', store.dsnync def start_store(app, url, workers=0, **kw):
      '''Equivalent to :func:`.create_store` for most cases excepts when the
      ``url`` is for a pulsar store not yet started.
      In this case, a :class:`.PulsarDS` is started.
      '''
      store = create_store(url, **kw)
      if store.name == 'pulsar':
          client = store.client()
          try:
              await client.ping()
          except ConnectionRefusedError:
              host = localhost(store._host)
              if not host:
                  raise
              cfg = await send('arbiter', 'run', start_pulsar_ds,
                               host, workers)
              store._host = cfg.addresses[0]
              dsn = store.buildurl()
              store = create_store(dsn, **kw)
      app.cfg.set('data_store', store.dsn)
docs: Equivalent to :func:`.create_store` for most cases excepts when the
      ``url`` is for a pulsar store not yet started.
      In this case, a :class:`.PulsarDS` is started.