viam.gen.app.datapipelines.v1.data_pipelines_pb2

@generated by mypy-protobuf. Do not edit manually! isort:skip_file

Attributes

`DESCRIPTOR`
`DATA_PIPELINE_RUN_STATUS_UNSPECIFIED`
`DATA_PIPELINE_RUN_STATUS_SCHEDULED`
`DATA_PIPELINE_RUN_STATUS_STARTED`
`DATA_PIPELINE_RUN_STATUS_COMPLETED`
`DATA_PIPELINE_RUN_STATUS_FAILED`
`Global___DataPipelineRunStatus`
`Global___DataPipeline`
`Global___GetDataPipelineRequest`
`Global___GetDataPipelineResponse`
`Global___ListDataPipelinesRequest`
`Global___ListDataPipelinesResponse`
`Global___CreateDataPipelineRequest`
`Global___CreateDataPipelineResponse`
`Global___RenameDataPipelineRequest`
`Global___RenameDataPipelineResponse`
`Global___DeleteDataPipelineRequest`
`Global___DeleteDataPipelineResponse`
`Global___EnableDataPipelineRequest`
`Global___EnableDataPipelineResponse`
`Global___DisableDataPipelineRequest`
`Global___DisableDataPipelineResponse`
`Global___ListDataPipelineRunsRequest`
`Global___ListDataPipelineRunsResponse`
`Global___DataPipelineRun`

Classes

`DataPipelineRunStatus`
`DataPipeline`	Abstract base class for protocol messages.
`GetDataPipelineRequest`	Abstract base class for protocol messages.
`GetDataPipelineResponse`	Abstract base class for protocol messages.
`ListDataPipelinesRequest`	Abstract base class for protocol messages.
`ListDataPipelinesResponse`	Abstract base class for protocol messages.
`CreateDataPipelineRequest`	Abstract base class for protocol messages.
`CreateDataPipelineResponse`	Abstract base class for protocol messages.
`RenameDataPipelineRequest`	Abstract base class for protocol messages.
`RenameDataPipelineResponse`	Abstract base class for protocol messages.
`DeleteDataPipelineRequest`	Abstract base class for protocol messages.
`DeleteDataPipelineResponse`	Abstract base class for protocol messages.
`EnableDataPipelineRequest`	Abstract base class for protocol messages.
`EnableDataPipelineResponse`	Abstract base class for protocol messages.
`DisableDataPipelineRequest`	Abstract base class for protocol messages.
`DisableDataPipelineResponse`	Abstract base class for protocol messages.
`ListDataPipelineRunsRequest`	Abstract base class for protocol messages.
`ListDataPipelineRunsResponse`	Abstract base class for protocol messages.
`DataPipelineRun`	Abstract base class for protocol messages.

Module Contents

viam.gen.app.datapipelines.v1.data_pipelines_pb2.DESCRIPTOR: google.protobuf.descriptor.FileDescriptor

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.DataPipelineRunStatus: Bases: _DataPipelineRunStatus

viam.gen.app.datapipelines.v1.data_pipelines_pb2.DATA_PIPELINE_RUN_STATUS_UNSPECIFIED: DataPipelineRunStatus

viam.gen.app.datapipelines.v1.data_pipelines_pb2.DATA_PIPELINE_RUN_STATUS_SCHEDULED: DataPipelineRunStatus

viam.gen.app.datapipelines.v1.data_pipelines_pb2.DATA_PIPELINE_RUN_STATUS_STARTED: DataPipelineRunStatus

viam.gen.app.datapipelines.v1.data_pipelines_pb2.DATA_PIPELINE_RUN_STATUS_COMPLETED: DataPipelineRunStatus

viam.gen.app.datapipelines.v1.data_pipelines_pb2.DATA_PIPELINE_RUN_STATUS_FAILED: DataPipelineRunStatus

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___DataPipelineRunStatus = DataPipelineRunStatus

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.DataPipeline(*, id: str = ..., organization_id: str = ..., name: str = ..., mql_binary: collections.abc.Iterable[bytes] | None = ..., schedule: str = ..., enabled: bool = ..., created_on: google.protobuf.timestamp_pb2.Timestamp | None = ..., updated_at: google.protobuf.timestamp_pb2.Timestamp | None = ..., data_source_type: app.data.v1.data_pb2.TabularDataSourceType.ValueType | None = ...)

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

id: str

organization_id: str: The associated Viam organization ID.

name: str: A unique identifier at the org level.

schedule: str: A cron expression representing the expected execution schedule in UTC (note this also defines the input time window; an hourly schedule would process 1 hour of data at a time).

enabled: bool: Whether or not the pipeline is enabled.

data_source_type: app.data.v1.data_pb2.TabularDataSourceType.ValueType: The type of data source for the pipeline. If not specified, default is standard data storage.

mql_binary() → google.protobuf.internal.containers.RepeatedScalarFieldContainer[bytes]: A MongoDB aggregation pipeline as a list of BSON documents, where each document is one stage in the pipeline.

created_on() → google.protobuf.timestamp_pb2.Timestamp: The time the pipeline was created.

updated_at() → google.protobuf.timestamp_pb2.Timestamp: The time the pipeline was last updated.

HasField(field_name: _HasFieldArgType) → bool

Checks if a certain field is set for the message.

For a oneof group, checks if any field inside is set. Note that if the field_name is not defined in the message descriptor, ValueError will be raised.

Parameters:: field_name (str) – The name of the field to check for presence.
Returns:: Whether a value has been set for the named field.
Return type:: bool
Raises:: ValueError – if the field_name is not a member of this message.

WhichOneof(oneof_group: _WhichOneofArgType__data_source_type) → _WhichOneofReturnType__data_source_type | None

Returns the name of the field that is set inside a oneof group.

If no field is set, returns None.

Parameters:: oneof_group (str) – the name of the oneof group to check.
Returns:: The name of the group that is set, or None.
Return type:: str or None
Raises:: ValueError – no group with the given name exists

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___DataPipeline = DataPipeline

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineRequest(*, id: str = ...)

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

id: str: The ID of the data pipeline to retrieve.

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___GetDataPipelineRequest = GetDataPipelineRequest

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.GetDataPipelineResponse(*, data_pipeline: Global___DataPipeline | None = ...)

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

data_pipeline() → Global___DataPipeline

HasField(field_name: _HasFieldArgType) → bool

Checks if a certain field is set for the message.

For a oneof group, checks if any field inside is set. Note that if the field_name is not defined in the message descriptor, ValueError will be raised.

Parameters:: field_name (str) – The name of the field to check for presence.
Returns:: Whether a value has been set for the named field.
Return type:: bool
Raises:: ValueError – if the field_name is not a member of this message.

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___GetDataPipelineResponse = GetDataPipelineResponse

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesRequest(*, organization_id: str = ...)

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

organization_id: str: The associated Viam organization ID.

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___ListDataPipelinesRequest = ListDataPipelinesRequest

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.ListDataPipelinesResponse(*, data_pipelines: collections.abc.Iterable[Global___DataPipeline] | None = ...)

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

data_pipelines() → google.protobuf.internal.containers.RepeatedCompositeFieldContainer[Global___DataPipeline]

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___ListDataPipelinesResponse = ListDataPipelinesResponse

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineRequest(*, organization_id: str = ..., name: str = ..., mql_binary: collections.abc.Iterable[bytes] | None = ..., schedule: str = ..., enable_backfill: bool | None = ..., data_source_type: app.data.v1.data_pb2.TabularDataSourceType.ValueType | None = ...)

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

organization_id: str: The associated Viam organization ID.

name: str: A unique identifier at the org level.

schedule: str: A cron expression representing the expected execution schedule in UTC (note this also defines the input time window; an hourly schedule would process 1 hour of data at a time).

enable_backfill: bool: When true, pipeline runs will be scheduled for the organization’s past data.

data_source_type: app.data.v1.data_pb2.TabularDataSourceType.ValueType: The type of data source for the pipeline. If not specified, default is standard data storage.

mql_binary() → google.protobuf.internal.containers.RepeatedScalarFieldContainer[bytes]: A MongoDB aggregation pipeline as a list of BSON documents, where each document is one stage in the pipeline.

HasField(field_name: _HasFieldArgType) → bool

Checks if a certain field is set for the message.

For a oneof group, checks if any field inside is set. Note that if the field_name is not defined in the message descriptor, ValueError will be raised.

Parameters:: field_name (str) – The name of the field to check for presence.
Returns:: Whether a value has been set for the named field.
Return type:: bool
Raises:: ValueError – if the field_name is not a member of this message.

WhichOneof(oneof_group: _WhichOneofArgType__data_source_type) → _WhichOneofReturnType__data_source_type | None

WhichOneof(oneof_group: _WhichOneofArgType__enable_backfill) → _WhichOneofReturnType__enable_backfill | None

Returns the name of the field that is set inside a oneof group.

If no field is set, returns None.

Parameters:: oneof_group (str) – the name of the oneof group to check.
Returns:: The name of the group that is set, or None.
Return type:: str or None
Raises:: ValueError – no group with the given name exists

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___CreateDataPipelineRequest = CreateDataPipelineRequest

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.CreateDataPipelineResponse(*, id: str = ...)

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

id: str: The ID of the newly created data pipeline.

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___CreateDataPipelineResponse = CreateDataPipelineResponse

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.RenameDataPipelineRequest(*, id: str = ..., name: str = ...)

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

id: str: The ID of the data pipeline to rename.

name: str: A unique identifier at the organization level.

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___RenameDataPipelineRequest = RenameDataPipelineRequest

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.RenameDataPipelineResponse

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___RenameDataPipelineResponse = RenameDataPipelineResponse

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineRequest(*, id: str = ...)

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

id: str: The ID of the data pipeline to delete.

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___DeleteDataPipelineRequest = DeleteDataPipelineRequest

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.DeleteDataPipelineResponse

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___DeleteDataPipelineResponse = DeleteDataPipelineResponse

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.EnableDataPipelineRequest(*, id: str = ...)

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

id: str: The ID of the data pipeline to enable.

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___EnableDataPipelineRequest = EnableDataPipelineRequest

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.EnableDataPipelineResponse

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___EnableDataPipelineResponse = EnableDataPipelineResponse

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.DisableDataPipelineRequest(*, id: str = ...)

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

id: str: The ID of the data pipeline to disable.

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___DisableDataPipelineRequest = DisableDataPipelineRequest

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.DisableDataPipelineResponse

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___DisableDataPipelineResponse = DisableDataPipelineResponse

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.ListDataPipelineRunsRequest(*, id: str = ..., page_size: int = ..., page_token: str = ...)

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

id: str: The ID of the data pipeline to list runs for.

page_size: int: pagination fields

page_token: str

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___ListDataPipelineRunsRequest = ListDataPipelineRunsRequest

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.ListDataPipelineRunsResponse(*, pipeline_id: str = ..., runs: collections.abc.Iterable[Global___DataPipelineRun] | None = ..., next_page_token: str = ...)

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

pipeline_id: str: The ID of the data pipeline the runs are for.

next_page_token: str: A token to retrieve the next page of results.

runs() → google.protobuf.internal.containers.RepeatedCompositeFieldContainer[Global___DataPipelineRun]: The runs that were run.

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___ListDataPipelineRunsResponse = ListDataPipelineRunsResponse

class viam.gen.app.datapipelines.v1.data_pipelines_pb2.DataPipelineRun(*, id: str = ..., start_time: google.protobuf.timestamp_pb2.Timestamp | None = ..., end_time: google.protobuf.timestamp_pb2.Timestamp | None = ..., data_start_time: google.protobuf.timestamp_pb2.Timestamp | None = ..., data_end_time: google.protobuf.timestamp_pb2.Timestamp | None = ..., status: Global___DataPipelineRunStatus = ..., error_message: str = ...)

Bases: google.protobuf.message.Message

Abstract base class for protocol messages.

Protocol message classes are almost always generated by the protocol compiler. These generated types subclass Message and implement the methods shown below.

id: str: The ID of the run.

status: Global___DataPipelineRunStatus: The status of the run.

error_message: str: The error message if the run failed.

start_time() → google.protobuf.timestamp_pb2.Timestamp: The time the run started.

end_time() → google.protobuf.timestamp_pb2.Timestamp: The time the run ended.

data_start_time() → google.protobuf.timestamp_pb2.Timestamp: The start time of the data that was processed in the run.

data_end_time() → google.protobuf.timestamp_pb2.Timestamp: The end time of the data that was processed in the run.

HasField(field_name: _HasFieldArgType) → bool

Checks if a certain field is set for the message.

For a oneof group, checks if any field inside is set. Note that if the field_name is not defined in the message descriptor, ValueError will be raised.

Parameters:: field_name (str) – The name of the field to check for presence.
Returns:: Whether a value has been set for the named field.
Return type:: bool
Raises:: ValueError – if the field_name is not a member of this message.

type viam.gen.app.datapipelines.v1.data_pipelines_pb2.Global___DataPipelineRun = DataPipelineRun