Consistent querying with erroneous data ingestion

A system comprising:

• a source data store associated with a first schema;
• a data storage system associated with a second schema that is different from the first schema;
• one or more processors;
• and
• one or more computer-readable media storing instructions which, when executed by the one or more processors, cause the system to perform operations comprising:
• receiving a query for data stored in a target data storage system, wherein the data comprises one or more semantic objects;
• determining, by a query analyzer of the data storage system, a query type of the query;
• identifying, for each semantic object of the one or more semantic objects, an error state, wherein:
• the error state indicates whether an error occurred during ingestion of the semantic object from a source data store to the target data storage system, and
• the error state of each semantic object is identified as:
• (i) a first failure state, (ii) a second failure state, or (iii) a success state;
• computing a query watermark associated with the query based on the query type and the error state of each semantic object;
• generating a query result comprising (i) the one or more semantic objects and (ii) at least one of:
• the query watermark or information based on the query watermark;
• and
• providing the query result.

One or more non-transitory computer-readable media storing instructions which, when executed by one or more processors, cause the one or more processors to perform operations comprising:

• receiving a query for data stored in a target data storage system, wherein the data comprises one or more semantic objects;
• determining, by a query analyzer of the data storage system, a query type of the query;
• identifying, for each semantic object of the one or more semantic objects, an error state, wherein:
• the error state indicates whether an error occurred during ingestion of the semantic object from a source data store to the target data storage system, and
• the error state of each semantic object is identified as:
• (i) a first failure state, (ii) a second failure state, or (iii) a success state;
• computing a query watermark associated with the query based on the query type and the error state of each semantic object;
• generating a query result comprising (i) the one or more semantic objects and (ii) at least one of:
• the query watermark or information based on the query watermark;
• and
• providing the query result to a user or an entity.