Hi I am trying to use Java Emitter to create entities of dataflow and datajobs linked to it. Those jobs will have relations to datasets as input and output. However when i tried to write dataflow:

MetadataChangeProposalWrapper mcpw = MetadataChangeProposalWrapper.builder()
        .entityType("dataflow")
        .entityUrn("urn:li:dataflow:(urn:li:dataPlatform:kafka,trace-pipeline,PROD)")
        .upsert()
        .aspect(new DataFlowInfo()
                .setName("Trace pipeline")
                .setDescription("Pipeline for trace service")
        )
        .build();

i am able to successfully emit it

emitter.emit(mcpw, new Callback()

but then when executing graphql query:

graphql query
{
  search(input: { type: DATA_FLOW, query: "*", start: 0, count: 10 }) {
    start
    count
    total
    searchResults {
      entity{
        urn
        type
        ...on DataFlow {
            cluster
         }
      }
    }
  }
}

i get following error:

response
{
  "errors": [
    {
      "message": "The field at path '/search/searchResults[0]/entity' was declared as a non null type, but the code involved in retrieving data has wrongly returned a null value.  The graphql specification requires that the parent field be set to null, or if that is non nullable that it bubble up null to its parent and so on. The non-nullable type is 'Entity' within parent type 'SearchResult'",
      "path": [
        "search",
        "searchResults",
        0,
        "entity"
      ],
      "extensions": {
        "classification": "NullValueInNonNullableField"
      }
    }
  ],
  "data": {
    "search": null
  }
}

so basically how such dataflow entity should look like? Did i miss some required fields? And how from entities documentation i can know which fields are optional and which are mandatory? thx

@green-football-43791 is this related to the graphql regression? ^

I am using version v0.8.23

@big-carpet-38439 ^