Source

The source object allows you to query information about a particular source in a given job.

Arguments

When querying for a source, the following arguments are available. Note that if you do not include a runId, it will default to the most recent run of the specified job:

Fetching data...

Below we show some illustrative example queries and outline the schema of this source object.

Example Queries

Source information

The query below pulls relevant information about a given source. For example, we could see the load time and the state (“pass”, “fail”, “error”) of that source.

{
 source(jobId: 123, uniqueId: "source.jaffle_shop.snowplow.event") {
   uniqueId
   sourceName
   name
   state
   maxLoadedAt
   criteria {
     warnAfter {
       period
       count
     }
     errorAfter {
       period
       count
     }
   }
   maxLoadedAtTimeAgoInS
 }
}

Fields

When querying for a source, the following fields are available:

Fetching data...