Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 5 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/Agent.java
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@
import com.atlan.exception.NotFoundException;
import com.atlan.model.enums.AgentType;
import com.atlan.model.enums.AgenticLifecycleStatus;
import com.atlan.model.enums.AgenticSource;
import com.atlan.model.enums.AtlanAnnouncementType;
import com.atlan.model.enums.CertificateStatus;
import com.atlan.model.fields.AtlanField;
Expand Down Expand Up @@ -89,6 +90,10 @@ public class Agent extends Asset implements IAgent, IAgentic, ICatalog, IAsset,
@Attribute
AgentType agentType;

/** Product surface this agentic asset was created from, so agents and skills can be attributed to their originating surface without slug pattern matching (AUT-1074). Mirrors AtlanAppWorkflow.source, which does the same for workflows (AUT-1028). */
@Attribute
AgenticSource agenticSource;

/** Version of this agentic asset as an epoch-millisecond timestamp. One Atlan entity per (slug, version) tuple. */
@Attribute
Long agenticVersion;
Expand Down
5 changes: 5 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/Agentic.java
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
import com.atlan.exception.ErrorCode;
import com.atlan.exception.InvalidRequestException;
import com.atlan.exception.NotFoundException;
import com.atlan.model.enums.AgenticSource;
import com.atlan.model.enums.AtlanAnnouncementType;
import com.atlan.model.enums.CertificateStatus;
import com.atlan.model.fields.AtlanField;
Expand Down Expand Up @@ -48,6 +49,10 @@ public class Agentic extends Asset implements IAgentic, ICatalog, IAsset, IRefer
@Builder.Default
String typeName = TYPE_NAME;

/** Product surface this agentic asset was created from, so agents and skills can be attributed to their originating surface without slug pattern matching (AUT-1074). Mirrors AtlanAppWorkflow.source, which does the same for workflows (AUT-1028). */
@Attribute
AgenticSource agenticSource;

/** Version of this agentic asset as an epoch-millisecond timestamp. One Atlan entity per (slug, version) tuple. */
@Attribute
Long agenticVersion;
Expand Down
4 changes: 4 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/AirflowDag.java
Original file line number Diff line number Diff line change
Expand Up @@ -62,6 +62,10 @@ public class AirflowDag extends Asset implements IAirflowDag, IAirflow, ICatalog
@Date
Long airflowRunEndTime;

/** Error message of the run in Airflow, populated when the run fails. */
@Attribute
String airflowRunErrorMessage;

/** Name of the run. */
@Attribute
String airflowRunName;
Expand Down
4 changes: 4 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/AirflowTask.java
Original file line number Diff line number Diff line change
Expand Up @@ -66,6 +66,10 @@ public class AirflowTask extends Asset implements IAirflowTask, IAirflow, ICatal
@Date
Long airflowRunEndTime;

/** Error message of the run in Airflow, populated when the run fails. */
@Attribute
String airflowRunErrorMessage;

/** Name of the run. */
@Attribute
String airflowRunName;
Expand Down
5 changes: 5 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/Artifact.java
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
import com.atlan.exception.ErrorCode;
import com.atlan.exception.InvalidRequestException;
import com.atlan.exception.NotFoundException;
import com.atlan.model.enums.AgenticSource;
import com.atlan.model.enums.AtlanAnnouncementType;
import com.atlan.model.enums.CertificateStatus;
import com.atlan.model.enums.FileType;
Expand Down Expand Up @@ -49,6 +50,10 @@ public class Artifact extends Asset implements IArtifact, IAgentic, IResource, I
@Builder.Default
String typeName = TYPE_NAME;

/** Product surface this agentic asset was created from, so agents and skills can be attributed to their originating surface without slug pattern matching (AUT-1074). Mirrors AtlanAppWorkflow.source, which does the same for workflows (AUT-1028). */
@Attribute
AgenticSource agenticSource;

/** Version of this agentic asset as an epoch-millisecond timestamp. One Atlan entity per (slug, version) tuple. */
@Attribute
Long agenticVersion;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,7 @@ public class AtlanAppDeployment extends Asset
@Attribute
String appId;

/** Target deployment environment where the app is installed (e.g. "atlan" for Atlan-managed infra, or a customer SDR deployment name for customer-managed infra). */
/** Target deployment environment where the app is installed, for example atlan (Atlan-managed infra) or a customer SDR deployment name (customer-managed infra). */
@Attribute
String atlanAppDeploymentName;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -65,7 +65,7 @@ public class AtlanAppInstalled extends Asset
@Attribute
String atlanAppDeploymentConfig;

/** Target deployment environment where the app is installed (e.g. "atlan" for Atlan-managed infra, or a customer SDR deployment name for customer-managed infra). */
/** Target deployment environment where the app is installed, for example atlan (Atlan-managed infra) or a customer SDR deployment name (customer-managed infra). */
@Attribute
String atlanAppDeploymentName;

Expand Down
13 changes: 13 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/AtlanAppWorkflow.java
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@
import com.atlan.exception.NotFoundException;
import com.atlan.model.enums.AtlanAnnouncementType;
import com.atlan.model.enums.AtlanAppWorkflowOwnership;
import com.atlan.model.enums.AtlanAppWorkflowRuntimeMode;
import com.atlan.model.enums.AtlanAppWorkflowSource;
import com.atlan.model.enums.AtlanAppWorkflowStatus;
import com.atlan.model.enums.CertificateStatus;
Expand Down Expand Up @@ -78,10 +79,18 @@ public class AtlanAppWorkflow extends Asset
@Singular
SortedSet<IAtlanAppTool> atlanAppTools;

/** Name of the SDR agent this workflow's runs are routed to (the atlan-prefixed task queue's agent). Indexed so an agent's runs can be filtered server-side by joining runs to their parent workflow (DISTR-832). */
@Attribute
String atlanAppWorkflowAgentName;

/** Map of all activity steps for the workflow (escaped JSON string). */
@Attribute
String atlanAppWorkflowDag;

/** SDR deployment name this workflow's runs execute under. Denormalized from the run-time config for run-history filtering and metric labels. */
@Attribute
String atlanAppWorkflowDeploymentName;

/** Error handling strategy for the workflow. */
@Attribute
AtlanAppErrorHandling atlanAppWorkflowErrorHandling;
Expand All @@ -95,6 +104,10 @@ public class AtlanAppWorkflow extends Asset
@Singular
SortedSet<IAppWorkflowRun> atlanAppWorkflowRuns;

/** Execution runtime for this workflow's runs (SDR or DIRECT). Set at workflow save and constant across the workflow's runs. */
@Attribute
AtlanAppWorkflowRuntimeMode atlanAppWorkflowRuntimeMode;

/** Slug of the workflow. */
@Attribute
String atlanAppWorkflowSlug;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -95,6 +95,10 @@ public class BigqueryRoutine extends Asset
@Attribute
String catalogDatasetGuid;

/** Cosmos collection in which this procedure exists. */
@Attribute
ICosmosMongoDBCollection cosmosMongoDBCollection;

/** Simple name of the database in which this SQL asset exists, or empty if it does not exist within a database. */
@Attribute
String databaseName;
Expand Down
5 changes: 5 additions & 0 deletions sdk/src/main/java/com/atlan/model/assets/Context.java
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
import com.atlan.exception.ErrorCode;
import com.atlan.exception.InvalidRequestException;
import com.atlan.exception.NotFoundException;
import com.atlan.model.enums.AgenticSource;
import com.atlan.model.enums.AtlanAnnouncementType;
import com.atlan.model.enums.CertificateStatus;
import com.atlan.model.fields.AtlanField;
Expand Down Expand Up @@ -48,6 +49,10 @@ public class Context extends Asset implements IContext, IAgentic, ICatalog, IAss
@Builder.Default
String typeName = TYPE_NAME;

/** Product surface this agentic asset was created from, so agents and skills can be attributed to their originating surface without slug pattern matching (AUT-1074). Mirrors AtlanAppWorkflow.source, which does the same for workflows (AUT-1028). */
@Attribute
AgenticSource agenticSource;

/** Version of this agentic asset as an epoch-millisecond timestamp. One Atlan entity per (slug, version) tuple. */
@Attribute
Long agenticVersion;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
import com.atlan.exception.ErrorCode;
import com.atlan.exception.InvalidRequestException;
import com.atlan.exception.NotFoundException;
import com.atlan.model.enums.AgenticSource;
import com.atlan.model.enums.AtlanAnnouncementType;
import com.atlan.model.enums.CertificateStatus;
import com.atlan.model.enums.FileType;
Expand Down Expand Up @@ -50,6 +51,10 @@ public class ContextArtifact extends Asset
@Builder.Default
String typeName = TYPE_NAME;

/** Product surface this agentic asset was created from, so agents and skills can be attributed to their originating surface without slug pattern matching (AUT-1074). Mirrors AtlanAppWorkflow.source, which does the same for workflows (AUT-1028). */
@Attribute
AgenticSource agenticSource;

/** Version of this agentic asset as an epoch-millisecond timestamp. One Atlan entity per (slug, version) tuple. */
@Attribute
Long agenticVersion;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
import com.atlan.exception.ErrorCode;
import com.atlan.exception.InvalidRequestException;
import com.atlan.exception.NotFoundException;
import com.atlan.model.enums.AgenticSource;
import com.atlan.model.enums.AtlanAnnouncementType;
import com.atlan.model.enums.CertificateStatus;
import com.atlan.model.enums.ContextLifecycleStatus;
Expand Down Expand Up @@ -50,6 +51,10 @@ public class ContextRepository extends Asset
@Builder.Default
String typeName = TYPE_NAME;

/** Product surface this agentic asset was created from, so agents and skills can be attributed to their originating surface without slug pattern matching (AUT-1074). Mirrors AtlanAppWorkflow.source, which does the same for workflows (AUT-1028). */
@Attribute
AgenticSource agenticSource;

/** Version of this agentic asset as an epoch-millisecond timestamp. One Atlan entity per (slug, version) tuple. */
@Attribute
Long agenticVersion;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -93,6 +93,16 @@ public class CosmosMongoDBCollection extends Asset
@Attribute
String cosmosMongoDBDatabaseQualifiedName;

/** User-defined functions that exist within this collection. */
@Attribute
@Singular
SortedSet<IFunction> cosmosMongoDBFunctions;

/** Stored procedures and triggers that exist within this collection. */
@Attribute
@Singular
SortedSet<IProcedure> cosmosMongoDBStoredProcedures;

/** Simple name of the database in which this SQL asset exists, or empty if it does not exist within a database. */
@Attribute
String databaseName;
Expand Down
Loading
Loading