Почему запрос к хранилищу данных потока данных не соответствует литеральной строке?

Question

Обновление: «состояние» не было проиндексировано :( Я проиндексировал это свойство, и запрос прошел нормально.

При запуске конвейера потока данных с DirectPipelineRunner мой запрос ничего не соответствует, хотя я могу см. сущности в хранилище данных. Когда я удаляю фильтр, он находит сущности и запускается.

Это кажется очень простым. Почему запрос не соответствует ни одной сущности?

    val readyToGoFilter = DatastoreHelper.makeFilter("state",
      PropertyFilter.Operator.EQUAL,
      DatastoreHelper.makeValue("SUBMITTED"))

    val query = Query.newBuilder()
      .addKind(kind)
      .setFilter(readyToGoFilter)
      .build()

    val in = sc
      .withName("FindBatch")
      .datastore(projectId, query)

Answer 1

Arg, "состояние" не было проиндексировано. Я проиндексировал это свойство, и оно работало нормально.