pyapacheatlas.core.entity.AtlasProcess#

class pyapacheatlas.core.entity.AtlasProcess(name, typeName, qualified_name, inputs, outputs, guid=None, **kwargs)#

A subclass of AtlasEntity that forces you to include the inputs and outputs of the process.

Parameters

  • name (str) – The name of this instance of an atlas entity.

  • typeName (str) – The type this entity should be.

  • qualified_name (str) – The unique “qualified name” of this instance of an atlas entity.

  • inputs (Union(list(dict), pyapacheatlas.core.entity.EntityDef)) – The list of input entities expressed as dicts and in minimum format (guid, type name, qualified name) or an AtlasEntity.

  • outputs (Union(list(dict), pyapacheatlas.core.entity.EntityDef)) – The list of output entities expressed as dicts and in minimum format (guid, type name, qualified name) or an AtlasEntity.

  • guid (Union(str,int), optional) – The guid to reference this entity by.

  • relationshipAttributes (dict, optional) – The relationship attributes representing how this entity is connected to others. Commonly used for “columns” to indicate entity is a column of a table or “query” to indicate a process entity is tied another process in a column lineage scenario.

  • attributes (dict, optional) – Additional attributes that your atlas entity may require.

  • classifications (dict, optional) – Classifications that may be applied to this atlas entity.

__init__(name, typeName, qualified_name, inputs, outputs, guid=None, **kwargs)#

Methods

__init__(name, typeName, qualified_name, …)

addBusinessAttribute(**kwargs)

Add one or many businessAttributes to the entity.

addClassification(*args)

Add one or many classifications to the entity.

addCustomAttribute(**kwargs)

Add one or many customAttributes to the entity.

addInput(*args)

Add one or many entities to the inputs.

addOutput(*args)

Add one or many entities to the outputs.

addRelationship(**kwargs)

Add one or many relationshipAttributes to the entity.

from_json(entity_json)

merge(other)

Combine the inputs and outputs of a process.

to_json([minimum])

Convert this atlas entity to a dict / json.

Attributes

inputs

Retrieves the inputs attribute for the process.

name

Retrieve the name of this entity.

outputs

Retrieves the outputs attribute for the process.

qualifiedName

Retrieve the qualifiedName of this entity.