Services

IssuesService

(synq.issues.issues.v1.IssuesService)

IssuesService is a service for managing Issues.

MarkInvestigating

MarkInvestigating (MarkInvestigatingRequest) MarkInvestigatingResponse

Mark issue as being investigated.

MarkFixed

MarkFixed (MarkFixedRequest) MarkFixedResponse

Mark issue as fixed.

MarkExpected

MarkExpected (MarkExpectedRequest) MarkExpectedResponse

Mark issue as expected.

MarkNoActionNeeded

MarkNoActionNeeded (MarkNoActionNeededRequest) MarkNoActionNeededResponse

Mark issue as no action needed.

PostComment

PostComment (PostCommentRequest) PostCommentResponse

Post a comment on an issue.

SqlTestsService

(synq.datachecks.sqltests.v1.SqlTestsService)

SqlTestsService is a service for managing SqlTests.

BatchUpsertSqlTests

BatchUpsertSqlTests (BatchUpsertSqlTestsRequest) BatchUpsertSqlTestsResponse

Upsert SqlTests based on a unique ID.

ListSqlTests

ListSqlTests (ListSqlTestsRequest) ListSqlTestsResponse

List SqlTests for given annotations.

BatchGetSqlTests

BatchGetSqlTests (BatchGetSqlTestsRequest) BatchGetSqlTestsResponse

Get SqlTests by their IDs.

BatchDeleteSqlTests

BatchDeleteSqlTests (BatchDeleteSqlTestsRequest) BatchDeleteSqlTestsResponse

Delete SqlTests by their IDs.

GetSqlTestAudit

GetSqlTestAudit (GetSqlTestAuditRequest) GetSqlTestAuditResponse

Get SqlTest audit from a given execution ID in jwt token.

DwhAgentService

(synq.agent.dwh.v1.DwhAgentService)

Connect

Connect (ConnectRequest) ConnectResponse

buf:lint:ignore RPC_NO_CLIENT_STREAMING

EntitiesService

(synq.entities.custom.v1.EntitiesService)

custom.EntitiesService is a service for managing custom entities. Entities can represent various data platform concepts such as services, consumers, applications or data pipelines that are not natively available in Synq.

Entities are identified by a unique identifier and can be created, updated, read and deleted.

UpsertEntity

UpsertEntity (UpsertEntityRequest) UpsertEntityResponse

Create or update an entity. If the entity does not exist, it will be created, otherwise it will be updated. Entities are identified and deduplicated by their Identifier in a scope of a given customer workspace.

DeleteEntity

DeleteEntity (DeleteEntityRequest) DeleteEntityResponse

Delete an entity by its identifier. If the entity does not exist, it will be a no-op.

ListEntities

ListEntities (ListEntitiesRequest) ListEntitiesResponse

List all entities.

GroupsService

(synq.entities.custom.v1.GroupsService)

It eliminates the need to keep state on client side to remember which assets were already created and which should be deleted. The server will keep track of the current state of the group and client can always send the intended new state. The server will calculate the diff and entities that are no longer present in the group will be removed.

Example:

  1. group has entities A, B, C at time t1
  2. client sends group with entities B, C, D at time t2
  3. server will remove entity A from the system and update the current state of the group to B, C, D

The service is designed to be idempotent and can be called multiple times with the same state without causing any side effects.

ListEntityGroups

ListEntityGroups (ListEntityGroupsRequest) ListEntityGroupsResponse

ListEntityGroups lists all groups.

UpsertEntitiesGroup

UpsertEntitiesGroup (UpsertEntitiesGroupRequest) UpsertEntitiesGroupResponse

UpsertEntitiesGroup updates current definition of group to the server. As part of the upsert operation the difference of entity ids is calculated between past state and the current state and entities that are no longer part of the group are removed.

DeleteEntitiesGroup

DeleteEntitiesGroup (DeleteEntitiesGroupRequest) DeleteEntitiesGroupResponse

DeleteEntitiesGroup deletes a group by its identifier. If the group does not exist, it will be a no-op.

RelationshipsService

(synq.entities.custom.v1.RelationshipsService)

RelationshipsService allow management of relationships between entities. Relationships can be created, updated, and deleted between 2 custom entities, or between a custom entity and Synq native entity.enum There is no option to create relationships between 2 Synq native entities (dbt model, BI dashboard, etc.).

UpsertRelationships

UpsertRelationships (UpsertRelationshipsRequest) UpsertRelationshipsResponse

Create or update relationships between entities. If the relationship already exists, it will be updated, otherwise it will be created.

DeleteRelationships

DeleteRelationships (DeleteRelationshipsRequest) DeleteRelationshipsResponse

Delete relationships between entities. If the relationship does not exist, it will be ignored.

ListRelationships

ListRelationships (ListRelationshipsRequest) ListRelationshipsResponse

Delete relationships between entities. If the relationship does not exist, it will be ignored.

ChecksRelationshipsService

(synq.entities.custom.v1.ChecksRelationshipsService)

UpsertCheckRelationships

UpsertCheckRelationships (UpsertCheckRelationshipsRequest) UpsertCheckRelationshipsResponse

DeleteCheckRelationships

DeleteCheckRelationships (DeleteCheckRelationshipsRequest) DeleteCheckRelationshipsResponse

FeaturesService

(synq.entities.custom.v1.FeaturesService)

UpsertEntityFeature

UpsertEntityFeature (UpsertEntityFeatureRequest) UpsertEntityFeatureResponse

Create or update an entity. If the entity does not exist, it will be created, otherwise it will be updated. Entities are identified and deduplicated by their Identifier in a scope of a given customer workspace.

DeleteEntityFeature

DeleteEntityFeature (DeleteEntityFeatureRequest) DeleteEntityFeatureResponse

Delete an entity by its identifier. If the entity does not exist, it will be a no-op.

ListEntityFeatures

ListEntityFeatures (ListEntityFeaturesRequest) ListEntityFeaturesResponse

List all entities.

TypesService

(synq.entities.custom.v1.TypesService)

TypesService is a service for managing custom entity types.

UpsertType

UpsertType (UpsertTypeRequest) UpsertTypeResponse

Create or update an entity. If the entity does not exist, it will be created, otherwise it will be updated. Entities are identified and deduplicated by their Identifier in a scope of a given customer workspace.

DeleteType

DeleteType (DeleteTypeRequest) DeleteTypeResponse

Delete an entity by its identifier. If the entity does not exist, it will be a no-op.

ListTypes

ListTypes (ListTypesRequest) ListTypesResponse

List all entities.

EntityIncidentsService

(synq.entities.status.v1.EntityIncidentsService)

EntityIncidentsService is the service which retrieves entity status.

GetIncidents

GetIncidents (GetIncidentsRequest) GetIncidentsResponse

Get specific entity status by its identifier.

BatchGetIncidents

BatchGetIncidents (BatchGetIncidentsRequest) BatchGetIncidentsResponse

Get multiple entity statuses by their identifiers.

EntityIssuesService

(synq.entities.status.v1.EntityIssuesService)

EntityIssuesService is the service which retrieves entity issues status.

GetIssuesStatus

GetIssuesStatus (GetIssuesStatusRequest) GetIssuesStatusResponse

Get specific entity status by its identifier.

BatchGetIssuesStatus

BatchGetIssuesStatus (BatchGetIssuesStatusRequest) BatchGetIssuesStatusResponse

Get multiple entity statuses by their identifiers.

EntitiesService

(synq.entities.entities.v1.EntitiesService)

EntitiesService is a service for retriving any entity.

GetEntity

GetEntity (GetEntityRequest) GetEntityResponse

Get specific entity by its identifier.

BatchGetEntities

BatchGetEntities (BatchGetEntitiesRequest) BatchGetEntitiesResponse

Get multiple entities by their identifiers.

EntityExecutionsService

(synq.entities.executions.v1.EntityExecutionsService)

UpsertExecution

UpsertExecution (UpsertExecutionRequest) UpsertExecutionResponse

Execution affects status of the custom entity

UpsertLogEntry

UpsertLogEntry (UpsertLogEntryRequest) UpsertLogEntryResponse

LogEntry is a log message for the custom entity

LineageService

(synq.entities.lineage.v1.LineageService)

LineageService allows you to fetch:

  • Entity level lineage from a starting point of one or more entities.
  • Column Level lineage from a starting point of multiple columns of a single entity.

GetLineage

GetLineage (GetLineageRequest) GetLineageResponse

DomainsService

(synq.domains.v1.DomainsService)

DomainsService can be used to manage domains.

Upsert

Upsert (UpsertRequest) UpsertResponse

Create or update a domain.

BatchGet

BatchGet (BatchGetRequest) BatchGetResponse

Get multiple domains by their identifiers.

FetchDomainWithSubDomains

FetchDomainWithSubDomains (FetchDomainWithSubDomainsRequest) FetchDomainWithSubDomainsResponse

Get a domain with its sub-domains

List

List (ListRequest) ListResponse

List all the domains in the current workspace.

Delete

Delete (DeleteRequest) DeleteResponse

Delete a domain by its identifier.

SetDefinition

SetDefinition (SetDefinitionRequest) SetDefinitionResponse

Set the definition for an existing domain.

AddDefinitionPart

AddDefinitionPart (AddDefinitionPartRequest) AddDefinitionPartResponse

Add definition part to the definition of an existing domain.

RemoveDefinitionPart

RemoveDefinitionPart (RemoveDefinitionPartRequest) RemoveDefinitionPartResponse

Remove definition part from the definition of an existing domain.

DomainMembersService

(synq.domains.members.v1.DomainMembersService)

DomainMembersService can be used to manage domain memberships.

AddDomainMembers

AddDomainMembers (AddDomainMembersRequest) AddDomainMembersResponse

Add domain members.

RemoveDomainMembers

RemoveDomainMembers (RemoveDomainMembersRequest) RemoveDomainMembersResponse

Remove domain members.

ListDomainMembers

ListDomainMembers (ListDomainMembersRequest) ListDomainMembersResponse

List domain members.

ListUserDomains

ListUserDomains (ListUserDomainsRequest) ListUserDomainsResponse

List domains for the given user.

SetDefaultUserDomain

SetDefaultUserDomain (SetDefaultUserDomainRequest) SetDefaultUserDomainResponse

Set default domain for user.

DbtService

(synq.ingest.dbt.v1.DbtService)

IngestInvocation

IngestInvocation (IngestInvocationRequest) IngestInvocationResponse

DwhService

(synq.ingest.dwh.v1.DwhService)

IngestObjectInformation

IngestObjectInformation (IngestObjectInformationRequest) IngestObjectInformationResponse

IngestSqlDefinitions

IngestSqlDefinitions (IngestSqlDefinitionsRequest) IngestSqlDefinitionsResponse

IngestSchemas

IngestSchemas (IngestSchemasRequest) IngestSchemasResponse

IngestObjectMetrics

IngestObjectMetrics (IngestObjectMetricsRequest) IngestObjectMetricsResponse

SqlMeshService

(synq.ingest.sqlmesh.v1.SqlMeshService)

IngestMetadata

IngestMetadata (IngestMetadataRequest) IngestMetadataResponse

IngestExecution

IngestExecution (IngestExecutionRequest) IngestExecutionResponse

DataproductsService

(synq.dataproducts.v1.DataproductsService)

DataproductsService can be used to manage data products.

Upsert

Upsert (UpsertRequest) UpsertResponse

Create or update a dataproduct.

Get

Get (GetRequest) GetResponse

Get multiple dataproducts by their identifiers.

List

List (ListRequest) ListResponse

List all the dataproducts in the current scope.

Delete

Delete (DeleteRequest) DeleteResponse

Delete a dataproduct by its identifier. Soft deletes by default. Optionally purge the dataproduct to release the identifier.

SetDefinition

SetDefinition (SetDefinitionRequest) SetDefinitionResponse

Set the definition for an existing dataproduct.

AddDefinitionPart

AddDefinitionPart (AddDefinitionPartRequest) AddDefinitionPartResponse

Add definition part to the definition of an existing dataproduct.

RemoveDefinitionPart

RemoveDefinitionPart (RemoveDefinitionPartRequest) RemoveDefinitionPartResponse

Remove definition part from the definition of an existing dataproduct.

Messages

IdentifierList

(synq.queries.v1.IdentifierList)

Resolves to entities matching any of the given identifiers.

FieldTypeDescription
identifiersrepeated Identifiernone

InDataPlatform

(synq.queries.v1.InDataPlatform)

Resolves to all entities that belong to the given data platform.

FieldTypeDescription
identifier DataPlatformIdentifiernone

InDataproduct

(synq.queries.v1.InDataproduct)

Resolves to all the assets that belong to the given data product.

FieldTypeDescription
identifier DataproductIdentifiernone

InFolder

(synq.queries.v1.InFolder)

Resolves to all entities belonging to the given folder structure.

FieldTypeDescription
pathrepeated stringnone

Unsupported

(synq.queries.v1.Unsupported)

Collects all the parts of the query that are currently unsupported in translation. These represent an internal structure that are not yet completely available on the API.

FieldTypeDescription
query_json stringnone

WithAnnotation

(synq.queries.v1.WithAnnotation)

Resolves to all entities that contain the annotation with the provided accepted value. In case of no given accepted value, all entities that carry the given annotation are returned.

FieldTypeDescription
name stringnone
oneof _accepted_value.accepted_valueoptional stringnone

WithNameSearch

(synq.queries.v1.WithNameSearch)

Resolves to all entities matching the given name search.

FieldTypeDescription
search_query stringnone

WithType

(synq.queries.v1.WithType)

Resolves to all the entities that have the provided type.

FieldTypeDescription
type Typenone

WithType.Type

(synq.queries.v1.WithType.Type)

FieldTypeDescription
oneof entity_type.default EntityTypeDefault SYNQ types
oneof entity_type.custom int32Custom types as defined through synq.entities.custom.v1.TypesService

IssuesCommand

(synq.issues.commands.v1.IssuesCommand)

Not to be used directly. Use the IssuesService instead when calling via API.

FieldTypeDescription
workspace stringnone
oneof action.mark_investigating MarkInvestigatingRequestnone
oneof action.mark_fixed MarkFixedRequestnone
oneof action.mark_expected MarkExpectedRequestnone
oneof action.mark_no_action_needed MarkNoActionNeededRequestnone
oneof action.post_comment PostCommentRequestnone

MarkExpectedRequest

(synq.issues.issues.v1.MarkExpectedRequest)

FieldTypeDescription
issue_id stringID of the issue to mark as expected.
actor ActorActor marking the issue as expected.
time TimestampTime at which the issue was marked as expected. Defaults to the current time.
require_no_existing_status boolIgnore status change if the issue already has a status.

MarkExpectedResponse

(synq.issues.issues.v1.MarkExpectedResponse)

MarkFixedRequest

(synq.issues.issues.v1.MarkFixedRequest)

FieldTypeDescription
issue_id stringID of the issue to mark as fixed.
actor ActorActor marking the issue as fixed.
time TimestampTime at which the issue was marked as fixed. Defaults to the current time.
require_no_existing_status boolIgnore status change if the issue already has a status.

MarkFixedResponse

(synq.issues.issues.v1.MarkFixedResponse)

MarkInvestigatingRequest

(synq.issues.issues.v1.MarkInvestigatingRequest)

FieldTypeDescription
issue_id stringID of the issue to mark as investigating.
actor ActorActor marking the issue as investigating.
time TimestampTime at which the issue was marked as investigating. Defaults to the current time.
require_no_existing_status boolIgnore status change if the issue already has a status.

MarkInvestigatingResponse

(synq.issues.issues.v1.MarkInvestigatingResponse)

MarkNoActionNeededRequest

(synq.issues.issues.v1.MarkNoActionNeededRequest)

FieldTypeDescription
issue_id stringID of the issue to mark as no action needed.
actor ActorActor marking the issue as no action needed.
time TimestampTime at which the issue was marked as no action needed. Defaults to the current time.
require_no_existing_status boolIgnore status change if the issue already has a status.

MarkNoActionNeededResponse

(synq.issues.issues.v1.MarkNoActionNeededResponse)

PostCommentRequest

(synq.issues.issues.v1.PostCommentRequest)

FieldTypeDescription
issue_id stringID of the issue to post a comment on.
actor ActorActor posting the comment.
comment stringComment to post.
time TimestampTime at which the comment was posted. Defaults to the current time.

PostCommentResponse

(synq.issues.issues.v1.PostCommentResponse)

FieldTypeDescription
comment_id stringnone

Actor

(synq.issues.actor.v1.Actor)

FieldTypeDescription
name stringnone
oneof user.slack SlackUsernone
oneof user.email EmailUsernone
oneof user.pagerduty PagerdutyUsernone

EmailUser

(synq.issues.actor.v1.EmailUser)

FieldTypeDescription
user_email stringnone

PagerdutyUser

(synq.issues.actor.v1.PagerdutyUser)

FieldTypeDescription
user_id stringnone

SlackUser

(synq.issues.actor.v1.SlackUser)

FieldTypeDescription
user_id stringnone

BatchDeleteSqlTestsRequest

(synq.datachecks.sqltests.v1.BatchDeleteSqlTestsRequest)

FieldTypeDescription
idsrepeated stringIDs of the SqlTests to delete.

BatchDeleteSqlTestsResponse

(synq.datachecks.sqltests.v1.BatchDeleteSqlTestsResponse)

BatchGetSqlTestsRequest

(synq.datachecks.sqltests.v1.BatchGetSqlTestsRequest)

FieldTypeDescription
idsrepeated stringIDs of the SqlTests to fetch.

BatchGetSqlTestsResponse

(synq.datachecks.sqltests.v1.BatchGetSqlTestsResponse)

FieldTypeDescription
sql_testsmap SqlTestsEntrynone

BatchGetSqlTestsResponse.SqlTestsEntry

(synq.datachecks.sqltests.v1.BatchGetSqlTestsResponse.SqlTestsEntry)

FieldTypeDescription
key stringnone
value SqlTestnone

BatchUpsertSqlTestsRequest

(synq.datachecks.sqltests.v1.BatchUpsertSqlTestsRequest)

FieldTypeDescription
sql_testsrepeated SqlTestList of SqlTests to upsert. The upsert is performed based on the unique path provided for each SqlTest.

BatchUpsertSqlTestsResponse

(synq.datachecks.sqltests.v1.BatchUpsertSqlTestsResponse)

FieldTypeDescription
created_idsrepeated stringIDs for which SqlTests were created without error.
updated_idsrepeated stringIDs for which SqlTests were updated without error.
errorsrepeated UpsertErrorErrors raised while upsert. This list will be empty if there were no errors.

BatchUpsertSqlTestsResponse.UpsertError

(synq.datachecks.sqltests.v1.BatchUpsertSqlTestsResponse.UpsertError)

Details of errors encountered during the upsert operation.

FieldTypeDescription
id stringnone
reason stringnone

GetSqlTestAuditRequest

(synq.datachecks.sqltests.v1.GetSqlTestAuditRequest)

GetSqlTestAuditResponse

(synq.datachecks.sqltests.v1.GetSqlTestAuditResponse)

FieldTypeDescription
audit SqlTestAuditnone

ListSqlTestsRequest

(synq.datachecks.sqltests.v1.ListSqlTestsRequest)

FieldTypeDescription
annotationsrepeated AnnotationOptional annotations to fetch SqlTests for.

ListSqlTestsResponse

(synq.datachecks.sqltests.v1.ListSqlTestsResponse)

FieldTypeDescription
sql_testsrepeated SqlTestnone

SqlTest

(synq.datachecks.sqltests.v1.SqlTest)

The SqlTest is a SQL test that is executed on a synq entity.

FieldTypeDescription
platform DataPlatformIdentifierIdentifier for the data platform which the SqlTest would be executed on.
id stringUnique resource identifier for the SqlTest. This is externally maintained and can be used to fetch/update/delete this test.
name stringHuman friendly name.
sql_expression stringA valid SQL expression which is the test.
recurrence_rule stringRecurrence rule for the execution schedule of the SqlTest.
annotationsrepeated AnnotationAnnotations for the given SqlTest.These help filter the SqlTests for later operations like listing by API, selection in UI, analytics, etc.
save_failures boolBoolean flag to to toggle saving of failure runs.

SqlTestAudit

(synq.datachecks.sqltests.v1.SqlTestAudit)

FieldTypeDescription
execution_id stringnone
rows_count int32none
result stringnone
created_at Timestampnone

AgentTask

(synq.agent.dwh.v1.AgentTask)

FieldTypeDescription
connection_id stringnone
task_id stringnone
oneof command.fetch_full_catalog FetchFullCatalogCommandnone
oneof command.fetch_full_metrics FetchFullMetricsCommandnone

ConnectRequest

(synq.agent.dwh.v1.ConnectRequest)

FieldTypeDescription
oneof message.hello Hellonone
oneof message.log Lognone

ConnectResponse

(synq.agent.dwh.v1.ConnectResponse)

FieldTypeDescription
tasksrepeated AgentTasknone

FetchFullCatalogCommand

(synq.agent.dwh.v1.FetchFullCatalogCommand)

FetchFullMetricsCommand

(synq.agent.dwh.v1.FetchFullMetricsCommand)

Hello

(synq.agent.dwh.v1.Hello)

FieldTypeDescription
name stringnone
build_version stringnone
build_time stringnone
available_connectionsrepeated AvailableConnectionnone

Hello.AvailableConnection

(synq.agent.dwh.v1.Hello.AvailableConnection)

FieldTypeDescription
connection_id stringIdentifier which will receive commands
name stringUser provided connection name
disabled boolIndicates that agent has that connection disabled
type stringType of the DWH, e.g. bigquery, duckdb, clickhouse
instance stringThis will be hostname in most cases
databasesrepeated stringEnabled databases to query if connection supports multiple databases, can be empty.

Log

(synq.agent.dwh.v1.Log)

FieldTypeDescription
time Timestampnone
message stringnone
level LogLevelnone

BigQueryConf

(synq.agent.dwh.v1.BigQueryConf)

BigQuery specific configuration

FieldTypeDescription
project_id stringGCP project ID
service_account_key stringService account key JSON
service_account_key_file stringLocation of service account key file
region stringRegion for BigQuery resources

ClickhouseConf

(synq.agent.dwh.v1.ClickhouseConf)

FieldTypeDescription
host stringHost address
port int32Port number
database stringDatabase name
username stringUsername for authentication
password stringPassword for authentication
allow_insecure boolWhether to use disable SSL for connection

Config

(synq.agent.dwh.v1.Config)

Config represents the main configuration for the DWH agent

FieldTypeDescription
agent AgentAgent configuration
synq SYNQSYNQ platform configuration
connectionsmap ConnectionsEntryMap of connection configurations

Config.Agent

(synq.agent.dwh.v1.Config.Agent)

Agent contains metadata about this agent instance

FieldTypeDescription
name stringName of the agent instance
tagsrepeated stringTags to categorize and organize the agent
log_level LogLevelnone
oneof _log_json.log_jsonoptional boolnone
oneof _log_report_caller.log_report_calleroptional boolnone

Config.Connection

(synq.agent.dwh.v1.Config.Connection)

Connection represents a database connection configuration

FieldTypeDescription
name stringName of the connection
disabled boolnone
parallelism int32How many queries to DWH can be executed in parallel, defaults to 2
oneof config.bigquery BigQueryConfnone
oneof config.clickhouse ClickhouseConfnone
oneof config.databricks DatabricksConfnone
oneof config.mysql MySQLConfnone
oneof config.postgres PostgresConfnone
oneof config.redshift RedshiftConfnone
oneof config.snowflake SnowflakeConfnone

Config.ConnectionsEntry

(synq.agent.dwh.v1.Config.ConnectionsEntry)

FieldTypeDescription
key stringnone
value Connectionnone

Config.SYNQ

(synq.agent.dwh.v1.Config.SYNQ)

SYNQ contains authentication and connection details for the SYNQ platform

FieldTypeDescription
client_id stringClient ID for OAuth authentication
client_secret stringClient secret for OAuth authentication
endpoint stringSYNQ API agent endpoint (host:port)
ingest_endpoint stringSYNQ API ingest endpoint (host:port)
oauth_url stringOAuth authentication URL

DatabricksConf

(synq.agent.dwh.v1.DatabricksConf)

FieldTypeDescription
workspace_url stringnone
oneof _auth_token.auth_tokenoptional stringnone
oneof _auth_client.auth_clientoptional stringnone
oneof _auth_secret.auth_secretoptional stringnone
oneof _warehouse.warehouseoptional stringnone
refresh_table_metrics boolnone
refresh_table_metrics_use_scan boolnone
fetch_table_tags boolnone
use_show_create_table boolnone

MySQLConf

(synq.agent.dwh.v1.MySQLConf)

MySQL specific configuration

FieldTypeDescription
host stringHost address
port int32Port number
database stringDatabase name
username stringUsername for authentication
password stringPassword for authentication
allow_insecure boolWhether to allow insecure connections
paramsmap ParamsEntryAdditional connection parameters

MySQLConf.ParamsEntry

(synq.agent.dwh.v1.MySQLConf.ParamsEntry)

FieldTypeDescription
key stringnone
value stringnone

PostgresConf

(synq.agent.dwh.v1.PostgresConf)

Postgres specific configuration

FieldTypeDescription
host stringHost address
port int32Port number
database stringDatabase name
username stringUsername for authentication
password stringPassword for authentication
allow_insecure boolWhether to allow insecure connections

RedshiftConf

(synq.agent.dwh.v1.RedshiftConf)

Redshift specific configuration

FieldTypeDescription
host stringHost address
port int32Port number
database stringDatabase name
username stringUsername for authentication
password stringPassword for authentication
freshness_from_query_logs boolEstimate table freshness based on query logs

SnowflakeConf

(synq.agent.dwh.v1.SnowflakeConf)

Snowflake specific configuration

FieldTypeDescription
account stringSnowflake account identifier
warehouse stringVirtual warehouse to use
role stringRole to assume
username stringUsername for authentication
password stringPassword for authentication
private_key stringContent of Private key used for Snowflake authentication
databasesrepeated stringDatabase to connect to
use_get_ddl boolUse GET_DDL to determine queries used for table/view creation

ScopeAuthorization

(synq.v1.ScopeAuthorization)

FieldTypeDescription
scopesrepeated Scopenone

DeleteEntityRequest

(synq.entities.custom.v1.DeleteEntityRequest)

DeleteEntityRequest is the request message for the DeleteEntity method.

FieldTypeDescription
id IdentifierIdentifier of the entity to delete.

DeleteEntityResponse

(synq.entities.custom.v1.DeleteEntityResponse)

DeleteEntityResponse is the response message for the DeleteEntity method.

ListEntitiesRequest

(synq.entities.custom.v1.ListEntitiesRequest)

ListEntitiesResponse

(synq.entities.custom.v1.ListEntitiesResponse)

FieldTypeDescription
entitiesrepeated Entitynone

UpsertEntityRequest

(synq.entities.custom.v1.UpsertEntityRequest)

UpsertEntityRequest is the request message for the UpsertEntity method.

FieldTypeDescription
entity EntityThe entity to create or update.

UpsertEntityResponse

(synq.entities.custom.v1.UpsertEntityResponse)

UpsertEntityResponse is the response message for the UpsertEntity method.

DeleteEntitiesGroupRequest

(synq.entities.custom.v1.DeleteEntitiesGroupRequest)

FieldTypeDescription
group_id stringnone

DeleteEntitiesGroupResponse

(synq.entities.custom.v1.DeleteEntitiesGroupResponse)

Group

(synq.entities.custom.v1.Group)

Group is a collection of entities.

FieldTypeDescription
group_id stringIdentifier of the group.
entity_idsrepeated IdentifierIdentifiers of entities that belong to the group.
created_at TimestampTimestamp when the group was created.
updated_at TimestampTimestamp when the group was last updated.

ListEntityGroupsRequest

(synq.entities.custom.v1.ListEntityGroupsRequest)

ListEntityGroupsResponse

(synq.entities.custom.v1.ListEntityGroupsResponse)

FieldTypeDescription
entities_groupsrepeated Groupnone

UpsertEntitiesGroupRequest

(synq.entities.custom.v1.UpsertEntitiesGroupRequest)

FieldTypeDescription
group Groupnone
dry_run boolnone

UpsertEntitiesGroupResponse

(synq.entities.custom.v1.UpsertEntitiesGroupResponse)

FieldTypeDescription
deleted_idsrepeated Identifiernone

DeleteRelationshipsRequest

(synq.entities.custom.v1.DeleteRelationshipsRequest)

FieldTypeDescription
relationshipsrepeated Relationshipnone

DeleteRelationshipsResponse

(synq.entities.custom.v1.DeleteRelationshipsResponse)

ListRelationshipsRequest

(synq.entities.custom.v1.ListRelationshipsRequest)

FieldTypeDescription
idsrepeated IdentifierReturn relationships for the given entity_id. Either upstream or downstream.

ListRelationshipsResponse

(synq.entities.custom.v1.ListRelationshipsResponse)

FieldTypeDescription
relationshipsrepeated Relationshipnone

Relationship

(synq.entities.custom.v1.Relationship)

FieldTypeDescription
upstream Identifiernone
downstream Identifiernone

UpsertRelationshipsRequest

(synq.entities.custom.v1.UpsertRelationshipsRequest)

FieldTypeDescription
relationshipsrepeated Relationshipnone

UpsertRelationshipsResponse

(synq.entities.custom.v1.UpsertRelationshipsResponse)

CheckRelationship

(synq.entities.custom.v1.CheckRelationship)

FieldTypeDescription
check Identifiernone
checked Identifiernone
checked_columnsrepeated stringnone

DeleteCheckRelationshipsRequest

(synq.entities.custom.v1.DeleteCheckRelationshipsRequest)

FieldTypeDescription
check_relationshipsrepeated CheckRelationshipnone

DeleteCheckRelationshipsResponse

(synq.entities.custom.v1.DeleteCheckRelationshipsResponse)

UpsertCheckRelationshipsRequest

(synq.entities.custom.v1.UpsertCheckRelationshipsRequest)

FieldTypeDescription
check_relationshipsrepeated CheckRelationshipnone

UpsertCheckRelationshipsResponse

(synq.entities.custom.v1.UpsertCheckRelationshipsResponse)

DeleteEntityFeatureRequest

(synq.entities.custom.v1.DeleteEntityFeatureRequest)

FieldTypeDescription
entity_id IdentifierIdentifier of the entity to delete feature from.
feature_id stringIdentifier of the feature to delete.

DeleteEntityFeatureResponse

(synq.entities.custom.v1.DeleteEntityFeatureResponse)

Feature

(synq.entities.custom.v1.Feature)

FieldTypeDescription
workspace stringImmutable workspace identifier that this entity belongs to.
entity_id IdentifierThe identifier of the entity to create or update feature for.
feature_id stringIdentifier of the feature. Can be any string, e.g. “sql” for SQL feature. Use same identifier to update the feature. Do not use random identifier as it will create a new feature on every update.
oneof feature.sql_definition SqlDefinitionOnly one feature per entity.
oneof feature.git_file_reference GitFileReferenceMultiple features per entity.
oneof feature.code CodeMultiple features per entity.
oneof feature.schema SchemaOnly one feature per entity.
oneof feature.check_category CheckCategoryOnly one feature per entity.
created_at TimestampTimestamp when the entity was created.
updated_at TimestampTimestamp when the entity was last updated.
deleted_at TimestampTimestamp when the entity was deleted. If this is set, the entity is considered deleted.

ListEntityFeaturesRequest

(synq.entities.custom.v1.ListEntityFeaturesRequest)

FieldTypeDescription
entity_id IdentifierIdentifier of the entity to get features for.

ListEntityFeaturesResponse

(synq.entities.custom.v1.ListEntityFeaturesResponse)

FieldTypeDescription
featuresrepeated FeatureList of features for the entity.

UpsertEntityFeatureRequest

(synq.entities.custom.v1.UpsertEntityFeatureRequest)

FieldTypeDescription
feature FeatureThe feature to create or update.

UpsertEntityFeatureResponse

(synq.entities.custom.v1.UpsertEntityFeatureResponse)

DeleteTypeRequest

(synq.entities.custom.v1.DeleteTypeRequest)

FieldTypeDescription
type_id int32Identifier of the custom entity type to delete.

DeleteTypeResponse

(synq.entities.custom.v1.DeleteTypeResponse)

ListTypesRequest

(synq.entities.custom.v1.ListTypesRequest)

ListTypesResponse

(synq.entities.custom.v1.ListTypesResponse)

FieldTypeDescription
typesrepeated TypeList of entities.

UpsertTypeRequest

(synq.entities.custom.v1.UpsertTypeRequest)

FieldTypeDescription
type TypeEntity to create or update.

UpsertTypeResponse

(synq.entities.custom.v1.UpsertTypeResponse)

Code

(synq.entities.custom.features.v1.Code)

Code feature represents a code snippet associated with the entity. If support for code parsing and dependency extraction is needed use SqlDefinition.

FieldTypeDescription
name stringMight be e.g. name of the file or a function.
code_type CodeTypeType of the code.
content stringContent of the code. Displayed in the UI.

Schema

(synq.entities.custom.features.v1.Schema)

Schema represents a schema of a table like entity

FieldTypeDescription
state_at TimestampTime when the schema was defined, will default to now if not set.
columnsrepeated SchemaColumnColumns of the schema Columns are ordered by ordinal_position, it has to be defined for all or none of the columns, when not defined, ordinal positions are attached according to the order of columns in the list.

SchemaColumn

(synq.entities.custom.features.v1.SchemaColumn)

FieldTypeDescription
name stringHuman readable name of the column as present in dbt or data warehouse.
native_type stringNative data type of the column as present in data warehouse.
description stringDescription of the column
ordinal_position int32Ordinal position of the column in the table, starting from 1
is_struct boolIndicates that the column type could be used as a struct/json in a data warehouse
is_repeated boolIndicates that the column is a repeated field in a data warehouse (e.g. array)
fieldsrepeated SchemaColumnFieldFields inside of the struct/record like column

SchemaColumnField

(synq.entities.custom.features.v1.SchemaColumnField)

FieldTypeDescription
name stringHuman readable name of the column as present in dbt or data warehouse.
native_type stringNative data type of the column as present in data warehouse.
description stringDescription of the column
ordinal_position int32Ordinal position of the column in the struct, starting from 1
is_struct boolIndicates that the field type could be used as a struct/json in a data warehouse
is_repeated boolIndicates that the field is a repeated field in a data warehouse (e.g. array)
fieldsrepeated SchemaColumnFieldFields inside of the struct/record like field

GitFileReference

(synq.entities.custom.features.v1.GitFileReference)

GitFileReference represents a reference to a file in a git repository.

FieldTypeDescription
repository_url stringURL of the git repository. Preferably SSH clone URL.
branch_name stringName of the branch in the git repository.
file_path stringPath to the file in the git repository.

SqlDefinition

(synq.entities.custom.features.v1.SqlDefinition)

SqlDefinition is a feature that allows to define lineage via SQL for a custom entity. Used to generate dependencies and other metadata. If parsed successfully, it will provide a code and column level lineage. Can be used to define simplified transformation of data which component performs using e.g. INSERT INTO foo SELECT * FROM bar.

FieldTypeDescription
state_at TimestampTime when the sql was defined, will default to now if not set.
dialect SqlDialectSQL dialect used in the SQL.
sql stringFinal form of the SQL as executed in the database/data warehouse. Must be a valid SQL in the selected dialect.

CheckCategory

(synq.entities.custom.features.v1.CheckCategory)

Checks feature indicates that the entity is testing in some way different entity. To define the kind of the check use the kind field. The package field is optional. It is used to categorize the entities which check other entities.

FieldTypeDescription
package stringGrouping of check kinds. e.g. “gcs”, “sql”, “queue”
kind stringKind of the check. e.g “not_null”, “unique”, “foreign_key”, “row_count”.
oneof _category.categoryoptional stringExplicit name of the Check category. If it is not defined categorisation rules are applied based on package + kind.

BatchGetIncidentsRequest

(synq.entities.status.v1.BatchGetIncidentsRequest)

BatchGetIncidentsRequest is the request message for the BatchGetIssues method.

FieldTypeDescription
requestsrepeated GetIncidentsRequestnone

BatchGetIncidentsResponse

(synq.entities.status.v1.BatchGetIncidentsResponse)

BatchGetIncidentsResponse is the response message for the BatchGetIssues method.

FieldTypeDescription
responsesrepeated GetIncidentsResponsenone

GetIncidentsRequest

(synq.entities.status.v1.GetIncidentsRequest)

GetIncidentsRequest is the request message for the GetEntity method.

FieldTypeDescription
id IdentifierIdentifier of the entity to get incidents for.
fetch_upstream_incidents boolRetrieve incidents of upstream entities.

GetIncidentsResponse

(synq.entities.status.v1.GetIncidentsResponse)

GetIncidentsResponse is the response message for the GetEntity method.

FieldTypeDescription
id IdentifierIdentifier of the entity.
entity_open_incidentsrepeated EntityIncidentOpen incident associated with the entity requested.
upstream_open_incidentsrepeated EntityIncidentOpen incidents associated with the upstream entities if requested.

EntityIncident

(synq.entities.status.v1.EntityIncident)

FieldTypeDescription
id stringUnique identifier of the incident.
url stringURL of the incident.
name stringName of the incident give by the user.
created_by stringInformation about author of the incident.
created_at TimestampTime when the incident was created.
updated_by stringInformation about the user who last updated the incident.
updated_at TimestampTime when the incident was last updated.
is_resolved boolIndicates if all issues inside the incident are resolved.

BatchGetIssuesStatusRequest

(synq.entities.status.v1.BatchGetIssuesStatusRequest)

BatchGetIssuesStatusRequest is the request message for the BatchGetIssues method.

FieldTypeDescription
requestsrepeated GetIssuesStatusRequestnone

BatchGetIssuesStatusResponse

(synq.entities.status.v1.BatchGetIssuesStatusResponse)

BatchGetIssuesStatusResponse is the response message for the BatchGetIssues method.

FieldTypeDescription
responsesrepeated GetIssuesStatusResponsenone

GetIssuesStatusRequest

(synq.entities.status.v1.GetIssuesStatusRequest)

GetIssuesStatusRequest is the request message for the GetEntity method.

FieldTypeDescription
id IdentifierIdentifier of the entity to get status for.
fetch_upstream_status boolRetrieve status of upstream entities.

GetIssuesStatusResponse

(synq.entities.status.v1.GetIssuesStatusResponse)

GetIssuesStatusResponse is the response message for the GetEntity method.

FieldTypeDescription
id IdentifierIdentifier of the entity.
entity_issues_status IssueStatusStatus of the entity requested.
entity_issues_summary IssuesSummarynone
upstream_issues_status IssueStatusOptionally, the status of all upstream entities.
upstream_issues_summary IssuesSummarynone

GetIssuesStatusResponse.IssuesSummary

(synq.entities.status.v1.GetIssuesStatusResponse.IssuesSummary)

FieldTypeDescription
total_count int32Number of issues for the entity.
warn_count int32Number of issues for the entity with status ‘warn’.
error_count int32Number of issues for the entity with status ‘error’.
critical_count int32Number of issues for the entity with status ‘critical’.

Entity

(synq.entities.v1.Entity)

Entity is the base type for all entities in the system. Its always attached to a given client workspace and can be uniquely identified by its id.

FieldTypeDescription
workspace stringImmutable workspace identifier that this entity belongs to.
id IdentifierUnique identifier for this entity.
type_id int32Id of custom type or default type when 0
name stringName of the entity that is displayed to the user.
description stringDescription of the entity that is displayed in relevant contexts. Can contain Markdown.
created_at TimestampTimestamp when the entity was created.
updated_at TimestampTimestamp when the entity was last updated.
deleted_at TimestampTimestamp when the entity was deleted. If this is set, the entity is considered deleted.
synq_path stringReturn only value. Synq Path to the entity. This is a unique path that can be used to access the entity in the Synq’s UI.
synq_catalog_url stringReturn only value. Synq URL to the entity. This is a unique URL that can be used to access the entity in the Synq’s UI.
annotationsrepeated AnnotationAnnotations attached to the entity. Annotations are key-value pairs that can be used to store metadata about the entity.

AirflowDagIdentifier

(synq.entities.v1.AirflowDagIdentifier)

FieldTypeDescription
integration_id stringSynq integration_id that identifies the Airflow instance
dag_id stringAirflow dag_id that identifies the DAG

AirflowTaskIdentifier

(synq.entities.v1.AirflowTaskIdentifier)

FieldTypeDescription
integration_id stringSynq integration_id that identifies the Airflow instance
dag_id stringAirflow dag_id that identifies the DAG
task_id stringAirflow task_id that identifies the task within the DAG

BigqueryTableIdentifier

(synq.entities.v1.BigqueryTableIdentifier)

FieldTypeDescription
project stringBigQuery project
dataset stringBigQuery dataset id
table stringBigQuery table name

ClickhouseTableIdentifier

(synq.entities.v1.ClickhouseTableIdentifier)

FieldTypeDescription
host stringClickhouse host inclusive of port
schema stringClickhouse database
table stringClickhouse table

CustomIdentifier

(synq.entities.v1.CustomIdentifier)

FieldTypeDescription
id stringId that identifies the custom entity The Id should be unique within the custom entity Identifier.

DatabricksTableIdentifier

(synq.entities.v1.DatabricksTableIdentifier)

FieldTypeDescription
workspace stringURL of Databricks workspace
catalog stringDatabricks catalog
schema stringDatabricks schema
table stringDatabricks table or view

DataproductIdentifier

(synq.entities.v1.DataproductIdentifier)

FieldTypeDescription
id stringDataproduct id that identifies the Dataproduct

DbtCloudNodeIdentifier

(synq.entities.v1.DbtCloudNodeIdentifier)

FieldTypeDescription
project_id stringYour dbt Cloud project id
account_id stringYour dbt Cloud account id
node_id stringDbt node_id that identifies one of dbt DAG nodes (model, test, etc)

DbtCoreNodeIdentifier

(synq.entities.v1.DbtCoreNodeIdentifier)

FieldTypeDescription
integration_id stringSynq integration_id that identifies the dbt Core project
node_id stringDbt node_id that identifies one of dbt DAG nodes (model, test, etc)

Identifier

(synq.entities.v1.Identifier)

Identifier is a unique reference to an entity in Synq system. Entity identifiers are designed to closely mimic identifiers used by data platforms and tools. To construct an identifier, you need to know the kind of the entity and the ids that you would normally use to identify it in the data platform or tool. For example, to identify a table in BigQuery, you would need to know the project, dataset, and table names.

FieldTypeDescription
oneof id.dbt_core_node DbtCoreNodeIdentifierDbt node that identifies one of dbt DAG nodes (model, test, etc) in dbt Core project
oneof id.dbt_cloud_node DbtCloudNodeIdentifierDbt node that identifies one of dbt DAG nodes (model, test, etc) in dbt Cloud project
oneof id.bigquery_table BigqueryTableIdentifierBigQuery table identifier
oneof id.snowflake_table SnowflakeTableIdentifierSnowflake table identifier
oneof id.redshift_table RedshiftTableIdentifierRedshift table identifier
oneof id.postgres_table PostgresTableIdentifierPostgres table identifier
oneof id.mysql_table MysqlTableIdentifierMysql table identifier
oneof id.clickhouse_table ClickhouseTableIdentifierClickhouse table identifier
oneof id.databricks_table DatabricksTableIdentifierDatabricks table identifier
oneof id.airflow_dag AirflowDagIdentifierAirflow DAG identifier
oneof id.airflow_task AirflowTaskIdentifierAirflow task identifier within a given DAG
oneof id.custom CustomIdentifierCustom identifier to be used with all custom created entities
oneof id.dataproduct DataproductIdentifierDataproduct identifier
oneof id.synq_path SynqPathIdentifierSynqPath identifier

MysqlTableIdentifier

(synq.entities.v1.MysqlTableIdentifier)

FieldTypeDescription
host stringMysql host inclusive of port
schema stringMysql database
table stringMysql table

PostgresTableIdentifier

(synq.entities.v1.PostgresTableIdentifier)

FieldTypeDescription
host stringPostgres host inclusive of port
database stringPostgres database
schema stringPostgres schema
table stringPostgres table

RedshiftTableIdentifier

(synq.entities.v1.RedshiftTableIdentifier)

FieldTypeDescription
cluster stringRedshift cluster
database stringRedshift database
schema stringRedshift schema
table stringRedshift table

SnowflakeTableIdentifier

(synq.entities.v1.SnowflakeTableIdentifier)

FieldTypeDescription
account stringSnowflake account
database stringSnowflake database
schema stringSnowflake schema
table stringSnowflake table

SynqPathIdentifier

(synq.entities.v1.SynqPathIdentifier)

FieldTypeDescription
path stringSynq path that identifies the Synq entity, needs to be one of supported paths

Type

(synq.entities.v1.Type)

Custom entity type that is used to categorize custom entities.

FieldTypeDescription
workspace stringImmutable workspace identifier that this custom entity type belongs to.
type_id int32none
name stringName of the custom entity type that is displayed to the user.
svg_icon bytesSVG icon of the custom entity type that is displayed to the user.
svg_icon_id stringSYNQ identifier used for CDN purposes, read-only.
created_at TimestampTimestamp when the custom entity type was created.
updated_at TimestampTimestamp when the custom entity type was last updated.
deleted_at TimestampTimestamp when the custom entity type was deleted. If this is set, the custom entity type is considered deleted.

Annotation

(synq.entities.v1.Annotation)

Annotations can be used to annotate any entity with a key:value pair. These annotations can be used for filtering and searching entities.

FieldTypeDescription
name stringString key for the annotation.
valuesrepeated stringOptional list of values that the annotation can carry.

BatchGetEntitiesRequest

(synq.entities.entities.v1.BatchGetEntitiesRequest)

BatchGetEntitiesRequest is the request message for the BatchGetEntities method.

FieldTypeDescription
idsrepeated IdentifierIdentifiers of the entities to get.

BatchGetEntitiesResponse

(synq.entities.entities.v1.BatchGetEntitiesResponse)

BatchGetEntitiesResponse is the response message for the BatchGetEntities method.

FieldTypeDescription
entitiesrepeated EntityThe entities that were retrieved.

GetEntityRequest

(synq.entities.entities.v1.GetEntityRequest)

GetEntityRequest is the request message for the GetEntity method.

FieldTypeDescription
id IdentifierIdentifier of the entity to get.

GetEntityResponse

(synq.entities.entities.v1.GetEntityResponse)

GetEntityResponse is the response message for the GetEntity method.

FieldTypeDescription
entity EntityThe entity that was retrieved.

Execution

(synq.entities.executions.v1.Execution)

FieldTypeDescription
id Identifiernone
status ExecutionStatusnone
message stringnone
created_at Timestampnone
started_at Timestampnone
finished_at Timestampnone
annotationsrepeated Annotationnone
extrasrepeated ExecutionExtranone

ExecutionExtra

(synq.entities.executions.v1.ExecutionExtra)

FieldTypeDescription
oneof extra.executed_sql stringnone

LogEntry

(synq.entities.executions.v1.LogEntry)

FieldTypeDescription
id Identifiernone
message stringnone
created_at Timestampnone
started_at Timestampnone
finished_at Timestampnone
annotationsrepeated Annotationnone

UpsertExecutionRequest

(synq.entities.executions.v1.UpsertExecutionRequest)

FieldTypeDescription
execution Executionnone

UpsertExecutionResponse

(synq.entities.executions.v1.UpsertExecutionResponse)

UpsertLogEntryRequest

(synq.entities.executions.v1.UpsertLogEntryRequest)

FieldTypeDescription
log_entry LogEntrynone

UpsertLogEntryResponse

(synq.entities.executions.v1.UpsertLogEntryResponse)

CllDetails

(synq.entities.lineage.v1.CllDetails)

FieldTypeDescription
columnsrepeated ColumnColumn details for CLL.
cll_state CllStateState of the CLL parse. UNSPECIFIED if CLL was not requested.
cll_messagesrepeated stringMessages related to CLL. e.g. Description of parse errors, etc.

Column

(synq.entities.lineage.v1.Column)

Column in a table-like asset (used in CLL mode).

FieldTypeDescription
column_id stringID string for the column. This is the parsed column name.
oneof _name.nameoptional stringOriginal column name as fetched from the table.
oneof _native_type.native_typeoptional stringColumn type as fetched from the table.

ColumnDependency

(synq.entities.lineage.v1.ColumnDependency)

Indicates data flow between columns. Source columns are used to compute value of target columns.

FieldTypeDescription
source_node_idx uint32Index of source node in the lineage nodes list.
source_node_column_id stringnone
target_node_idx uint32Index of target node in the lineage nodes list.
target_node_column_id stringnone

Lineage

(synq.entities.lineage.v1.Lineage)

Lineage defines the lineage of table-like entities.

FieldTypeDescription
nodesrepeated LineageNodeNodes in the lineage with their identities and columns.
node_dependenciesrepeated NodeDependencyAll edges in the lineage between nodes. This can be parsed to create a graph of all the nodes.
is_cll boolIndicates whether the lineage was filtered for column level lineage (CLL).
column_dependenciesrepeated ColumnDependencyDependencies between columns. Populated only for CLL.

LineageNode

(synq.entities.lineage.v1.LineageNode)

Node in a lineage graph representing one or more entities (e.g. database table).

FieldTypeDescription
idsrepeated IdentifierAll entities which have the same identity as this node. Must be at least one item. These are sorted by closeness to the type of the start point entities. e.g. if requesting lineage of a DBT source, first entity should be from DBT, similarly when viewing table it will be other tables.
position NodePositionPosition of the node in the lineage.
oneof _cll_details.cll_detailsoptional CllDetailsPopulated only for Column Level Lineage (CLL).

NodeDependency

(synq.entities.lineage.v1.NodeDependency)

Indicates data flow between nodes. Source nodes are used to compute value of target nodes.

FieldTypeDescription
source_node_idx uint32Index of source node in the lineage nodes list.
target_node_idx uint32Index of target node in the lineage nodes list.

EntitiesStartPoint

(synq.entities.lineage.v1.EntitiesStartPoint)

FieldTypeDescription
entitiesrepeated Identifiernone

EntityColumnsStartPoint

(synq.entities.lineage.v1.EntityColumnsStartPoint)

FieldTypeDescription
id Identifiernone
column_namesrepeated stringnone

GetLineageRequest

(synq.entities.lineage.v1.GetLineageRequest)

FieldTypeDescription
lineage_direction LineageDirectionnone
start_point GetLineageStartPointnone
oneof _max_depth.max_depthoptional int32none

GetLineageResponse

(synq.entities.lineage.v1.GetLineageResponse)

FieldTypeDescription
lineage Lineagenone

GetLineageStartPoint

(synq.entities.lineage.v1.GetLineageStartPoint)

Possible starting points to get lineage from.

FieldTypeDescription
oneof from.entities EntitiesStartPointnone
oneof from.entity_columns EntityColumnsStartPointnone

BigqueryIdentifier

(synq.platforms.v1.BigqueryIdentifier)

FieldTypeDescription
project stringBigQuery project

ClickhouseIdentifier

(synq.platforms.v1.ClickhouseIdentifier)

FieldTypeDescription
host stringClickhouse host inclusive of port
schema stringClickhouse database

DataPlatformIdentifier

(synq.platforms.v1.DataPlatformIdentifier)

DataPlatformIdentifier is a unique reference to a data platform integrated with Synq.

FieldTypeDescription
oneof id.unknown UnknownDataPlatformnone
oneof id.bigquery BigqueryIdentifiernone
oneof id.clickhouse ClickhouseIdentifiernone
oneof id.snowflake SnowflakeIdentifiernone
oneof id.redshift RedshiftIdentifiernone
oneof id.postgres PostgresIdentifiernone
oneof id.mysql MysqlIdentifiernone
oneof id.databricks DatabricksIdentifiernone

DatabricksIdentifier

(synq.platforms.v1.DatabricksIdentifier)

FieldTypeDescription
workspace stringURl of the databricks workspace

MysqlIdentifier

(synq.platforms.v1.MysqlIdentifier)

FieldTypeDescription
host stringMysql host inclusive of port

PostgresIdentifier

(synq.platforms.v1.PostgresIdentifier)

FieldTypeDescription
host stringPostgres host inclusive of port
database stringPostgres database

RedshiftIdentifier

(synq.platforms.v1.RedshiftIdentifier)

FieldTypeDescription
cluster stringRedshift cluster
database stringRedshift database

SnowflakeIdentifier

(synq.platforms.v1.SnowflakeIdentifier)

FieldTypeDescription
account stringSnowflake account
database stringSnowflake database

UnknownDataPlatform

(synq.platforms.v1.UnknownDataPlatform)

AssetSelectionQuery

(synq.domains.v1.AssetSelectionQuery)

FieldTypeDescription
partsrepeated QueryPartnone
operand QueryOperandnone

AssetSelectionQuery.QueryPart

(synq.domains.v1.AssetSelectionQuery.QueryPart)

FieldTypeDescription
oneof part.identifier_list IdentifierListnone
oneof part.with_name_search WithNameSearchnone
oneof part.with_type WithTypenone
oneof part.with_annotation WithAnnotationnone
oneof part.in_data_platform InDataPlatformnone
oneof part.in_folder InFoldernone
oneof part.query AssetSelectionQuerynone
oneof part.unsupported Unsupportednone

DomainDefinition

(synq.domains.v1.DomainDefinition)

FieldTypeDescription
partsrepeated Partnone

DomainDefinition.Part

(synq.domains.v1.DomainDefinition.Part)

FieldTypeDescription
id stringpart identifier
oneof part.identifier Identifiernone
oneof part.dataproduct DataproductIdentifiernone
oneof part.query AssetSelectionQuerynone

Domain

(synq.domains.v1.Domain)

FieldTypeDescription
id stringnone
name stringnone
description stringnone
created_at Timestampnone
oneof _deleted_at.deleted_atoptional Timestampnone
definition DomainDefinitionnone
oneof _parent_id.parent_idoptional stringnone

AddDefinitionPartRequest

(synq.domains.v1.AddDefinitionPartRequest)

FieldTypeDescription
domain_id stringnone
part Partnone

AddDefinitionPartResponse

(synq.domains.v1.AddDefinitionPartResponse)

BatchGetRequest

(synq.domains.v1.BatchGetRequest)

FieldTypeDescription
domain_idsrepeated stringnone

BatchGetResponse

(synq.domains.v1.BatchGetResponse)

FieldTypeDescription
domainsmap DomainsEntrynone

BatchGetResponse.DomainsEntry

(synq.domains.v1.BatchGetResponse.DomainsEntry)

FieldTypeDescription
key stringnone
value Domainnone

DeleteRequest

(synq.domains.v1.DeleteRequest)

FieldTypeDescription
domain_id stringnone

DeleteResponse

(synq.domains.v1.DeleteResponse)

FetchDomainWithSubDomainsRequest

(synq.domains.v1.FetchDomainWithSubDomainsRequest)

FieldTypeDescription
domain_id stringnone

FetchDomainWithSubDomainsResponse

(synq.domains.v1.FetchDomainWithSubDomainsResponse)

FieldTypeDescription
domainsmap DomainsEntrynone

FetchDomainWithSubDomainsResponse.DomainsEntry

(synq.domains.v1.FetchDomainWithSubDomainsResponse.DomainsEntry)

FieldTypeDescription
key stringnone
value Domainnone

ListRequest

(synq.domains.v1.ListRequest)

FieldTypeDescription
oneof _parent_id.parent_idoptional stringnone

ListResponse

(synq.domains.v1.ListResponse)

FieldTypeDescription
domainsrepeated Domainnone

RemoveDefinitionPartRequest

(synq.domains.v1.RemoveDefinitionPartRequest)

FieldTypeDescription
domain_id stringnone
part_id stringnone

RemoveDefinitionPartResponse

(synq.domains.v1.RemoveDefinitionPartResponse)

SetDefinitionRequest

(synq.domains.v1.SetDefinitionRequest)

FieldTypeDescription
domain_id stringnone
definition DomainDefinitionnone

SetDefinitionResponse

(synq.domains.v1.SetDefinitionResponse)

UpsertRequest

(synq.domains.v1.UpsertRequest)

FieldTypeDescription
id stringnone
name stringnone
description stringnone
oneof _parent_id.parent_idoptional stringnone

UpsertResponse

(synq.domains.v1.UpsertResponse)

DomainMembership

(synq.domains.members.v1.DomainMembership)

FieldTypeDescription
user_id stringnone
domain_id stringnone
is_default boolnone

AddDomainMembersRequest

(synq.domains.members.v1.AddDomainMembersRequest)

FieldTypeDescription
domain_id stringnone
user_idsrepeated stringnone

AddDomainMembersResponse

(synq.domains.members.v1.AddDomainMembersResponse)

ListDomainMembersRequest

(synq.domains.members.v1.ListDomainMembersRequest)

FieldTypeDescription
domain_id stringnone

ListDomainMembersResponse

(synq.domains.members.v1.ListDomainMembersResponse)

FieldTypeDescription
membershipsrepeated DomainMembershipnone

ListUserDomainsRequest

(synq.domains.members.v1.ListUserDomainsRequest)

FieldTypeDescription
user_id stringnone

ListUserDomainsResponse

(synq.domains.members.v1.ListUserDomainsResponse)

FieldTypeDescription
membershipsrepeated DomainMembershipnone

RemoveDomainMembersRequest

(synq.domains.members.v1.RemoveDomainMembersRequest)

FieldTypeDescription
domain_id stringnone
user_idsrepeated stringnone

RemoveDomainMembersResponse

(synq.domains.members.v1.RemoveDomainMembersResponse)

SetDefaultUserDomainRequest

(synq.domains.members.v1.SetDefaultUserDomainRequest)

FieldTypeDescription
domain_id stringnone
user_id stringnone

SetDefaultUserDomainResponse

(synq.domains.members.v1.SetDefaultUserDomainResponse)

DbtArtifact

(synq.ingest.dbt.v1.DbtArtifact)

https://docs.getdbt.com/reference/artifacts/dbt-artifacts

FieldTypeDescription
oneof artifact.manifest_json bytesnone
oneof artifact.run_results_json bytesnone
oneof artifact.catalog_json bytesnone
oneof artifact.sources_json bytesnone
oneof artifact.semantic_manifest_json bytesnone

IngestInvocationRequest

(synq.ingest.dbt.v1.IngestInvocationRequest)

FieldTypeDescription
argsrepeated stringArguments passed to the dbt executable
exit_code int32Exit code of the dbt command
std_out bytesStandard output log of the dbt command
std_err bytesStandard error log of the dbt command
environment_varsmap EnvironmentVarsEntryEnvironment variables collected during execution
artifactsrepeated DbtArtifactArtifacts generated by the dbt command
uploader_version stringVersion of the uploader tool
uploader_build_time stringBuild time of the uploader tool
git_context GitContextGit context of the project

IngestInvocationRequest.EnvironmentVarsEntry

(synq.ingest.dbt.v1.IngestInvocationRequest.EnvironmentVarsEntry)

FieldTypeDescription
key stringnone
value stringnone

IngestInvocationResponse

(synq.ingest.dbt.v1.IngestInvocationResponse)

IngestObjectInformationRequest

(synq.ingest.dwh.v1.IngestObjectInformationRequest)

FieldTypeDescription
connection_id stringnone
upload_id stringnone
state_at TimestampTime at which state was collected
objectsrepeated ObjectInformationnone

IngestObjectInformationResponse

(synq.ingest.dwh.v1.IngestObjectInformationResponse)

IngestObjectMetricsRequest

(synq.ingest.dwh.v1.IngestObjectMetricsRequest)

FieldTypeDescription
connection_id stringnone
upload_id stringnone
state_at TimestampTime at which state was collected
metricsrepeated ObjectMetricsnone

IngestObjectMetricsResponse

(synq.ingest.dwh.v1.IngestObjectMetricsResponse)

IngestSchemasRequest

(synq.ingest.dwh.v1.IngestSchemasRequest)

FieldTypeDescription
connection_id stringnone
upload_id stringnone
state_at TimestampTime at which state was collected
schemasrepeated Schemanone

IngestSchemasResponse

(synq.ingest.dwh.v1.IngestSchemasResponse)

IngestSqlDefinitionsRequest

(synq.ingest.dwh.v1.IngestSqlDefinitionsRequest)

FieldTypeDescription
connection_id stringnone
upload_id stringnone
state_at TimestampTime at which state was collected
sql_definitionsrepeated SqlDefinitionnone

IngestSqlDefinitionsResponse

(synq.ingest.dwh.v1.IngestSqlDefinitionsResponse)

Fqn

(synq.ingest.dwh.v1.Fqn)

FieldTypeDescription
instance_name stringnone
database_name stringnone
schema_name stringnone
object_name stringnone

ObjectInformation

(synq.ingest.dwh.v1.ObjectInformation)

FieldTypeDescription
fqn Fqnnone
object_native_type stringnone
is_view boolnone
is_table boolnone
tagsrepeated Tagnone
oneof _description.descriptionoptional stringnone

ObjectMetrics

(synq.ingest.dwh.v1.ObjectMetrics)

FieldTypeDescription
fqn Fqnnone
oneof _row_count.row_countoptional int64none
oneof _updated_at.updated_atoptional Timestampnone
oneof _size_bytes.size_bytesoptional int64none

Schema

(synq.ingest.dwh.v1.Schema)

FieldTypeDescription
fqn Fqnnone
columnsrepeated SchemaColumnnone

SchemaColumn

(synq.ingest.dwh.v1.SchemaColumn)

FieldTypeDescription
name stringnone
native_type stringnone
ordinal_position int32none
oneof _description.descriptionoptional stringnone
tagsrepeated Tagnone
is_struct boolnone
is_repeated boolnone
fieldsrepeated SchemaColumnFieldnone

SchemaColumnField

(synq.ingest.dwh.v1.SchemaColumnField)

FieldTypeDescription
name stringnone
native_type stringnone
oneof _description.descriptionoptional stringnone
ordinal_position int32none
is_struct boolnone
is_repeated boolnone
fieldsrepeated SchemaColumnFieldnone

SqlDefinition

(synq.ingest.dwh.v1.SqlDefinition)

FieldTypeDescription
fqn Fqnnone
sql stringnone

Tag

(synq.ingest.dwh.v1.Tag)

FieldTypeDescription
tag_name stringnone
tag_value stringnone

IngestExecutionRequest

(synq.ingest.sqlmesh.v1.IngestExecutionRequest)

FieldTypeDescription
commandrepeated stringCommand passed to the sqlmesh tool
exit_code int32Exit code of the sqlmesh command
std_out bytesStandard output log of the SqlMesh command
std_err bytesStandard error log of the SqlMesh command
environment_varsmap EnvironmentVarsEntryEnvironment variables collected during execution
uploader_version stringVersion of the uploader tool
uploader_build_time stringBuild time of the uploader tool
started_at TimestampTime at which the execution started
finished_at TimestampTime at which the execution finished
git_context GitContextGit context of the project

IngestExecutionRequest.EnvironmentVarsEntry

(synq.ingest.sqlmesh.v1.IngestExecutionRequest.EnvironmentVarsEntry)

FieldTypeDescription
key stringnone
value stringnone

IngestExecutionResponse

(synq.ingest.sqlmesh.v1.IngestExecutionResponse)

IngestMetadataRequest

(synq.ingest.sqlmesh.v1.IngestMetadataRequest)

FieldTypeDescription
api_meta bytesData from /api/meta
models bytesData from /api/models
model_detailsmap ModelDetailsEntryData from /api/models/
model_lineagemap ModelLineageEntryData from /api/lineage/
files bytesData from /api/files
file_contentmap FileContentEntryData from /api/file/
environments bytesData from /api/environments
uploader_version stringVersion of the uploader tool
uploader_build_time stringBuild time of the uploader tool
state_at TimestampTime at which state was collected
git_context GitContextGit context of the project
errorsrepeated ErrorOptional errors indicating why some data wasn’t loaded

IngestMetadataRequest.Error

(synq.ingest.sqlmesh.v1.IngestMetadataRequest.Error)

FieldTypeDescription
oneof _path.pathoptional stringnone
oneof _code.codeoptional int64none
message stringnone

IngestMetadataRequest.FileContentEntry

(synq.ingest.sqlmesh.v1.IngestMetadataRequest.FileContentEntry)

FieldTypeDescription
key stringnone
value bytesnone

IngestMetadataRequest.ModelDetailsEntry

(synq.ingest.sqlmesh.v1.IngestMetadataRequest.ModelDetailsEntry)

FieldTypeDescription
key stringnone
value bytesnone

IngestMetadataRequest.ModelLineageEntry

(synq.ingest.sqlmesh.v1.IngestMetadataRequest.ModelLineageEntry)

FieldTypeDescription
key stringnone
value bytesnone

IngestMetadataResponse

(synq.ingest.sqlmesh.v1.IngestMetadataResponse)

GitContext

(synq.ingest.git.v1.GitContext)

FieldTypeDescription
clone_url stringnone
branch stringnone
commit_sha stringnone

Callback

(synq.webhooks.v1.Callback)

FieldTypeDescription
url stringnone
action_name stringnone
oneof action.issues_command IssuesCommandnone

Event

(synq.webhooks.v1.Event)

FieldTypeDescription
workspace stringnone
event_id stringnone
event_time Timestampnone
event_type EventTypenone
oneof data.ping Pingnone
oneof data.issue_created IssueCreatednone
oneof data.issue_updated IssueUpdatednone
oneof data.issue_status_updated IssueStatusUpdatednone
oneof data.issue_closed IssueClosednone
callbacksrepeated Callbacknone

IssueClosed

(synq.webhooks.v1.IssueClosed)

FieldTypeDescription
issue IssueSummarynone

IssueCreated

(synq.webhooks.v1.IssueCreated)

FieldTypeDescription
issue IssueSummarynone

IssueStatusUpdated

(synq.webhooks.v1.IssueStatusUpdated)

FieldTypeDescription
issue IssueSummarynone

IssueSummary

(synq.webhooks.v1.IssueSummary)

FieldTypeDescription
issue_id stringnone
issue_group_id stringnone
issue_url stringnone
title stringSummary of the issue, what happened and where.
description stringDetailed description of the issue. In the Markdown format.
description_html stringDetailed description of the issue. In the HTML format.
trigger_entity IssueEntityEntity which triggered the issue.
directly_affected_entitiesrepeated IssueEntityEntities directly affected by the issue, not considering downstream ones.
started_at TimestampTime when the issue was triggered.
oneof _ended_at.ended_atoptional TimestampTime when the issue was closed.
trigger_run_id stringnone
trigger_name stringnone
trigger_message stringnone
status IssueStatusnone

IssueSummary.IssueEntity

(synq.webhooks.v1.IssueSummary.IssueEntity)

FieldTypeDescription
name stringnone
type_name stringnone
identifier Identifiernone
oneof _folder.folderoptional stringnone
entity_url stringnone

IssueUpdated

(synq.webhooks.v1.IssueUpdated)

FieldTypeDescription
issue IssueSummarynone

Ping

(synq.webhooks.v1.Ping)

Test event sent during a webhook setup.

FieldTypeDescription
message stringnone

AddDefinitionPartRequest

(synq.dataproducts.v1.AddDefinitionPartRequest)

FieldTypeDescription
product_identifier DataproductIdentifiernone
part Partnone

AddDefinitionPartResponse

(synq.dataproducts.v1.AddDefinitionPartResponse)

DeleteRequest

(synq.dataproducts.v1.DeleteRequest)

FieldTypeDescription
identifier DataproductIdentifiernone

DeleteResponse

(synq.dataproducts.v1.DeleteResponse)

GetRequest

(synq.dataproducts.v1.GetRequest)

FieldTypeDescription
identifiersrepeated DataproductIdentifiernone

GetResponse

(synq.dataproducts.v1.GetResponse)

FieldTypeDescription
productsrepeated Dataproductnone

ListRequest

(synq.dataproducts.v1.ListRequest)

FieldTypeDescription
include_deleted boolnone

ListResponse

(synq.dataproducts.v1.ListResponse)

FieldTypeDescription
productsrepeated Dataproductnone

RemoveDefinitionPartRequest

(synq.dataproducts.v1.RemoveDefinitionPartRequest)

FieldTypeDescription
product_identifier DataproductIdentifiernone
part_id stringnone

RemoveDefinitionPartResponse

(synq.dataproducts.v1.RemoveDefinitionPartResponse)

SetDefinitionRequest

(synq.dataproducts.v1.SetDefinitionRequest)

FieldTypeDescription
product_identifier DataproductIdentifiernone
definition DataproductDefinitionnone

SetDefinitionResponse

(synq.dataproducts.v1.SetDefinitionResponse)

UpsertRequest

(synq.dataproducts.v1.UpsertRequest)

FieldTypeDescription
oneof _identifier.identifieroptional DataproductIdentifiernone
title stringnone
description stringnone
folder stringnone
priority Prioritynone

UpsertResponse

(synq.dataproducts.v1.UpsertResponse)

FieldTypeDescription
identifier DataproductIdentifieridentifier of the updated or created dataproduct

Dataproduct

(synq.dataproducts.v1.Dataproduct)

FieldTypeDescription
identifier DataproductIdentifiernone
definition DataproductDefinitionnone
title stringnone
description stringnone
folder stringnone
priority Prioritynone
created_at Timestampnone
oneof _deleted_at.deleted_atoptional Timestampnone

AssetSelectionQuery

(synq.dataproducts.v1.AssetSelectionQuery)

FieldTypeDescription
partsrepeated QueryPartnone
operand QueryOperandnone

AssetSelectionQuery.QueryPart

(synq.dataproducts.v1.AssetSelectionQuery.QueryPart)

FieldTypeDescription
oneof part.identifier_list IdentifierListnone
oneof part.with_name_search WithNameSearchnone
oneof part.with_type WithTypenone
oneof part.with_annotation WithAnnotationnone
oneof part.in_data_platform InDataPlatformnone
oneof part.in_folder InFoldernone
oneof part.query AssetSelectionQuerynone
oneof part.unsupported Unsupportednone

DataproductDefinition

(synq.dataproducts.v1.DataproductDefinition)

FieldTypeDescription
partsrepeated Partnone

DataproductDefinition.Part

(synq.dataproducts.v1.DataproductDefinition.Part)

FieldTypeDescription
id stringpart identifier
oneof part.identifier Identifiernone
oneof part.query AssetSelectionQuerynone

Enums

QueryOperand

(synq.queries.v1.QueryOperand)

NameNumberDescription
QUERY_OPERAND_UNSPECIFIED0default to AND behaviour
QUERY_OPERAND_AND1none
QUERY_OPERAND_OR2none
QUERY_OPERAND_EXCEPT3none
QUERY_OPERAND_UPSTREAM4none
QUERY_OPERAND_DOWNSTREAM5none

LogLevel

(synq.agent.dwh.v1.LogLevel)

NameNumberDescription
LOG_LEVEL_UNSPECIFIED0none
LOG_LEVEL_INFO1none
LOG_LEVEL_WARN2none
LOG_LEVEL_ERROR3none

Config.Agent.LogLevel

(synq.agent.dwh.v1.Config.Agent.LogLevel)

NameNumberDescription
LOG_LEVEL_UNSPECIFIED0Defaults to info
LOG_LEVEL_TRACE1none
LOG_LEVEL_DEBUG2none
LOG_LEVEL_INFO3none
LOG_LEVEL_WARN4none
LOG_LEVEL_ERROR5none

Scope

(synq.v1.Scope)

NameNumberDescription
SCOPE_UNSPECIFIED0none
SCOPE_ISSUES_EDIT10none
SCOPE_ISSUES_READ11none
SCOPE_ENTITY_EDIT30none
SCOPE_ENTITY_READ31none
SCOPE_ENTITY_TYPE_EDIT32none
SCOPE_ENTITY_TYPE_READ33none
SCOPE_LINEAGE_EDIT34none
SCOPE_LINEAGE_READ35none
SCOPE_STATUS_READ40none
SCOPE_INGEST_DBT41none
SCOPE_INGEST_SQLMESH42none
SCOPE_INGEST_DWH43none
SCOPE_DATACHECKS_SQLTESTS_EDIT50none
SCOPE_DATACHECKS_SQLTESTS_READ51none
SCOPE_DATACHECKS_SQLTESTS_AUDIT_READ52none
SCOPE_EXECUTION_EDIT60none
SCOPE_EXECUTION_LOG_EDIT61none
SCOPE_EXECUTION_READ62none
SCOPE_HOOK70none
SCOPE_USER_READ91none
SCOPE_USER_ASSIGN92none
SCOPE_DATAPRODUCT_EDIT150none
SCOPE_DATAPRODUCT_READ151none
SCOPE_DOMAIN_EDIT160none
SCOPE_DOMAIN_READ161none

CodeType

(synq.entities.custom.features.v1.CodeType)

NameNumberDescription
CODE_TYPE_UNSPECIFIED0none
CODE_TYPE_SQL1none
CODE_TYPE_PYTHON2none
CODE_TYPE_JSON3none

SqlDialect

(synq.entities.custom.features.v1.SqlDialect)

NameNumberDescription
SQL_DIALECT_UNSPECIFIED0none
SQL_DIALECT_BIGQUERY1none
SQL_DIALECT_CLICKHOUSE2none
SQL_DIALECT_DATABRICKS3none
SQL_DIALECT_MYSQL4none
SQL_DIALECT_POSTGRESQL5none
SQL_DIALECT_REDSHIFT6none
SQL_DIALECT_SNOWFLAKE7none
SQL_DIALECT_DUCKDB8none

IssueStatus

(synq.entities.status.v1.IssueStatus)

NameNumberDescription
ISSUE_STATUS_UNSPECIFIED0none
ISSUE_STATUS_OK10none
ISSUE_STATUS_WARN20none
ISSUE_STATUS_ERROR30none
ISSUE_STATUS_CRITICAL40none

EntityType

(synq.entities.v1.EntityType)

NameNumberDescription
ENTITY_TYPE_UNSPECIFIED0none
ENTITY_TYPE_BQ_TABLE103none
ENTITY_TYPE_BQ_VIEW105none
ENTITY_TYPE_LOOKER_LOOK201none
ENTITY_TYPE_LOOKER_EXPLORE203none
ENTITY_TYPE_LOOKER_VIEW207none
ENTITY_TYPE_LOOKER_DASHBOARD208none
ENTITY_TYPE_DBT_MODEL301none
ENTITY_TYPE_DBT_TEST302none
ENTITY_TYPE_DBT_SOURCE303none
ENTITY_TYPE_DBT_PROJECT306none
ENTITY_TYPE_DBT_METRIC307none
ENTITY_TYPE_DBT_SNAPSHOT310none
ENTITY_TYPE_DBT_SEED311none
ENTITY_TYPE_DBT_ANALYSIS312none
ENTITY_TYPE_DBT_EXPOSURE313none
ENTITY_TYPE_DBT_GROUP314none
ENTITY_TYPE_DBT_CLOUD_PROJECT352none
ENTITY_TYPE_DBT_CLOUD_JOB353none
ENTITY_TYPE_SNOWFLAKE_TABLE503none
ENTITY_TYPE_SNOWFLAKE_VIEW508none
ENTITY_TYPE_REDSHIFT_TABLE803none
ENTITY_TYPE_REDSHIFT_VIEW805none
ENTITY_TYPE_TABLEAU_EMBEDDED1101none
ENTITY_TYPE_TABLEAU_PUBLISHED1102none
ENTITY_TYPE_TABLEAU_CUSTOM_SQL1103none
ENTITY_TYPE_TABLEAU_TABLE1104none
ENTITY_TYPE_TABLEAU_SHEET1105none
ENTITY_TYPE_TABLEAU_DASHBOARD1106none
ENTITY_TYPE_AIRFLOW_DAG1201none
ENTITY_TYPE_AIRFLOW_TASK1202none
ENTITY_TYPE_CLICKHOUSE_TABLE1303none
ENTITY_TYPE_CLICKHOUSE_VIEW1305none
ENTITY_TYPE_ANOMALY_MONITOR1403none
ENTITY_TYPE_ANOMALY_MONITOR_SEGMENT1404none
ENTITY_TYPE_SQLTEST_TEST1421none
ENTITY_TYPE_POSTGRES_TABLE1603none
ENTITY_TYPE_POSTGRES_VIEW1605none
ENTITY_TYPE_MYSQL_TABLE1703none
ENTITY_TYPE_MYSQL_VIEW1705none
ENTITY_TYPE_DATABRICKS_WAREHOUSE1801none
ENTITY_TYPE_DATABRICKS_TABLE1804none
ENTITY_TYPE_DATABRICKS_VIEW1805none
ENTITY_TYPE_DATABRICKS_JOB1807none
ENTITY_TYPE_DATABRICKS_NOTEBOOK1809none
ENTITY_TYPE_DATABRICKS_QUERY1810none
ENTITY_TYPE_DATABRICKS_DASHBOARD1811none
ENTITY_TYPE_SQLMESH_PROJECT1901none
ENTITY_TYPE_SQLMESH_SQL_MODEL1902none
ENTITY_TYPE_SQLMESH_PYTHON_MODEL1903none
ENTITY_TYPE_SQLMESH_EXTERNAL1904none
ENTITY_TYPE_SQLMESH_SEED1905none
ENTITY_TYPE_SQLMESH_AUDIT1906none
ENTITY_TYPE_SQLMESH_UNIT_TEST1907none
ENTITY_TYPE_SQLMESH_ENVIRONMENT1908none
ENTITY_TYPE_SQLMESH_SNAPSHOT1909none
ENTITY_TYPE_DUCKDB_TABLE2003none
ENTITY_TYPE_DUCKDB_VIEW2005none
ENTITY_TYPE_CUSTOM_ENTITY_GENERIC50000none
ENTITY_TYPE_CUSTOM_ENTITY_CUSTOM_TYPE_MIN50001none
ENTITY_TYPE_CUSTOM_ENTITY_CUSTOM_TYPE_MAX59999none

ExecutionStatus

(synq.entities.executions.v1.ExecutionStatus)

NameNumberDescription
EXECUTION_STATUS_UNSPECIFIED0none
EXECUTION_STATUS_OK1none
EXECUTION_STATUS_WARN2none
EXECUTION_STATUS_ERROR3none
EXECUTION_STATUS_CRITICAL4none

CllState

(synq.entities.lineage.v1.CllState)

NameNumberDescription
CLL_STATE_UNSPECIFIED0Unspecified state.
CLL_STATE_PARSE_FAILED1Parsing of the asset SQL failed. No upstream dependencies can be found.
CLL_STATE_EXTRACTION_FAILED2Extraction of the asset SQL failed. Some unsupported SQL features may be used. Some details might be missing.
CLL_STATE_RESOLUTION_FAILED3Not all columns or tables were found upstream, lineage is not complete.
CLL_STATE_OK10No known issues present.

NodePosition

(synq.entities.lineage.v1.NodePosition)

NameNumberDescription
NODE_POSITION_UNSPECIFIED0none
NODE_POSITION_START_NODE1Node is one of the requested start point.
NODE_POSITION_UPSTREAM2Node is upstream of the requested start point.
NODE_POSITION_DOWNSTREAM3Node is downstream of the requested start point.

LineageDirection

(synq.entities.lineage.v1.LineageDirection)

Direction of the lineage to query.

NameNumberDescription
LINEAGE_DIRECTION_UNSPECIFIED0none
LINEAGE_DIRECTION_UPSTREAM1none
LINEAGE_DIRECTION_DOWNSTREAM2none
LINEAGE_DIRECTION_UPSTREAM_DOWNSTREAM3none

Event.EventType

(synq.webhooks.v1.Event.EventType)

NameNumberDescription
EVENT_TYPE_UNSPECIFIED0none
EVENT_TYPE_PING10none
EVENT_TYPE_ISSUE_CREATED11none
EVENT_TYPE_ISSUE_UPDATED12none
EVENT_TYPE_ISSUE_STATUS_UPDATED13none
EVENT_TYPE_ISSUE_CLOSED14none

IssueSummary.IssueStatus

(synq.webhooks.v1.IssueSummary.IssueStatus)

NameNumberDescription
ISSUE_STATUS_UNSPECIFIED0none
ISSUE_STATUS_INVESTIGATING1none
ISSUE_STATUS_EXPECTED2none
ISSUE_STATUS_FIXED3none
ISSUE_STATUS_NO_ACTION_NEEDED4none

Dataproduct.Priority

(synq.dataproducts.v1.Dataproduct.Priority)

NameNumberDescription
PRIORITY_UNSPECIFIED0none
PRIORITY_P33none
PRIORITY_P24none
PRIORITY_P15none