stubs/google/cloud/dataflow.pyi - develop - githubmirror/oppia

stubs/google/cloud/dataflow.pyi
155 строк7 KB
Gabriel Fuentes
Black formatter staging (#23456)
05 окт 2025, 06:15
05 окт 2025, 06:1562ec95a
from google.cloud.dataflow_v1beta3.services.flex_templates_service.async_client import (
    FlexTemplatesServiceAsyncClient as FlexTemplatesServiceAsyncClient,
)
from google.cloud.dataflow_v1beta3.services.flex_templates_service.client import (
    FlexTemplatesServiceClient as FlexTemplatesServiceClient,
)
from google.cloud.dataflow_v1beta3.services.jobs_v1_beta3.async_client import (
    JobsV1Beta3AsyncClient as JobsV1Beta3AsyncClient,
)
from google.cloud.dataflow_v1beta3.services.jobs_v1_beta3.client import (
    JobsV1Beta3Client as JobsV1Beta3Client,
)
from google.cloud.dataflow_v1beta3.services.messages_v1_beta3.async_client import (
    MessagesV1Beta3AsyncClient as MessagesV1Beta3AsyncClient,
)
from google.cloud.dataflow_v1beta3.services.messages_v1_beta3.client import (
    MessagesV1Beta3Client as MessagesV1Beta3Client,
)
from google.cloud.dataflow_v1beta3.services.metrics_v1_beta3.async_client import (
    MetricsV1Beta3AsyncClient as MetricsV1Beta3AsyncClient,
)
from google.cloud.dataflow_v1beta3.services.metrics_v1_beta3.client import (
    MetricsV1Beta3Client as MetricsV1Beta3Client,
)
from google.cloud.dataflow_v1beta3.services.snapshots_v1_beta3.async_client import (
    SnapshotsV1Beta3AsyncClient as SnapshotsV1Beta3AsyncClient,
)
from google.cloud.dataflow_v1beta3.services.snapshots_v1_beta3.client import (
    SnapshotsV1Beta3Client as SnapshotsV1Beta3Client,
)
from google.cloud.dataflow_v1beta3.services.templates_service.async_client import (
    TemplatesServiceAsyncClient as TemplatesServiceAsyncClient,
)
from google.cloud.dataflow_v1beta3.services.templates_service.client import (
    TemplatesServiceClient as TemplatesServiceClient,
)
from google.cloud.dataflow_v1beta3.types.environment import (
    AutoscalingAlgorithm as AutoscalingAlgorithm,
    AutoscalingSettings as AutoscalingSettings,
    DebugOptions as DebugOptions,
    DefaultPackageSet as DefaultPackageSet,
    Disk as Disk,
    Environment as Environment,
    FlexResourceSchedulingGoal as FlexResourceSchedulingGoal,
    JobType as JobType,
    Package as Package,
    SdkHarnessContainerImage as SdkHarnessContainerImage,
    ShuffleMode as ShuffleMode,
    TaskRunnerSettings as TaskRunnerSettings,
    TeardownPolicy as TeardownPolicy,
    WorkerIPAddressConfiguration as WorkerIPAddressConfiguration,
    WorkerPool as WorkerPool,
    WorkerSettings as WorkerSettings,
)
from google.cloud.dataflow_v1beta3.types.jobs import (
    BigQueryIODetails as BigQueryIODetails,
    BigTableIODetails as BigTableIODetails,
    CheckActiveJobsRequest as CheckActiveJobsRequest,
    CheckActiveJobsResponse as CheckActiveJobsResponse,
    CreateJobRequest as CreateJobRequest,
    DatastoreIODetails as DatastoreIODetails,
    DisplayData as DisplayData,
    ExecutionStageState as ExecutionStageState,
    ExecutionStageSummary as ExecutionStageSummary,
    FailedLocation as FailedLocation,
    FileIODetails as FileIODetails,
    GetJobRequest as GetJobRequest,
    Job as Job,
    JobExecutionInfo as JobExecutionInfo,
    JobExecutionStageInfo as JobExecutionStageInfo,
    JobMetadata as JobMetadata,
    JobState as JobState,
    JobView as JobView,
    KindType as KindType,
    ListJobsRequest as ListJobsRequest,
    ListJobsResponse as ListJobsResponse,
    PipelineDescription as PipelineDescription,
    PubSubIODetails as PubSubIODetails,
    SdkVersion as SdkVersion,
    SnapshotJobRequest as SnapshotJobRequest,
    SpannerIODetails as SpannerIODetails,
    Step as Step,
    TransformSummary as TransformSummary,
    UpdateJobRequest as UpdateJobRequest,
)
from google.cloud.dataflow_v1beta3.types.messages import (
    AutoscalingEvent as AutoscalingEvent,
    JobMessage as JobMessage,
    JobMessageImportance as JobMessageImportance,
    ListJobMessagesRequest as ListJobMessagesRequest,
    ListJobMessagesResponse as ListJobMessagesResponse,
    StructuredMessage as StructuredMessage,
)
from google.cloud.dataflow_v1beta3.types.metrics import (
    ExecutionState as ExecutionState,
    GetJobExecutionDetailsRequest as GetJobExecutionDetailsRequest,
    GetJobMetricsRequest as GetJobMetricsRequest,
    GetStageExecutionDetailsRequest as GetStageExecutionDetailsRequest,
    JobExecutionDetails as JobExecutionDetails,
    JobMetrics as JobMetrics,
    MetricStructuredName as MetricStructuredName,
    MetricUpdate as MetricUpdate,
    ProgressTimeseries as ProgressTimeseries,
    StageExecutionDetails as StageExecutionDetails,
    StageSummary as StageSummary,
    WorkItemDetails as WorkItemDetails,
    WorkerDetails as WorkerDetails,
)
from google.cloud.dataflow_v1beta3.types.snapshots import (
    DeleteSnapshotRequest as DeleteSnapshotRequest,
    DeleteSnapshotResponse as DeleteSnapshotResponse,
    GetSnapshotRequest as GetSnapshotRequest,
    ListSnapshotsRequest as ListSnapshotsRequest,
    ListSnapshotsResponse as ListSnapshotsResponse,
    PubsubSnapshotMetadata as PubsubSnapshotMetadata,
    Snapshot as Snapshot,
    SnapshotState as SnapshotState,
)
from google.cloud.dataflow_v1beta3.types.streaming import (
    ComputationTopology as ComputationTopology,
    CustomSourceLocation as CustomSourceLocation,
    DataDiskAssignment as DataDiskAssignment,
    KeyRangeDataDiskAssignment as KeyRangeDataDiskAssignment,
    KeyRangeLocation as KeyRangeLocation,
    MountedDataDisk as MountedDataDisk,
    PubsubLocation as PubsubLocation,
    StateFamilyConfig as StateFamilyConfig,
    StreamLocation as StreamLocation,
    StreamingApplianceSnapshotConfig as StreamingApplianceSnapshotConfig,
    StreamingComputationRanges as StreamingComputationRanges,
    StreamingSideInputLocation as StreamingSideInputLocation,
    StreamingStageLocation as StreamingStageLocation,
    TopologyConfig as TopologyConfig,
)
from google.cloud.dataflow_v1beta3.types.templates import (
    ContainerSpec as ContainerSpec,
    CreateJobFromTemplateRequest as CreateJobFromTemplateRequest,
    DynamicTemplateLaunchParams as DynamicTemplateLaunchParams,
    FlexTemplateRuntimeEnvironment as FlexTemplateRuntimeEnvironment,
    GetTemplateRequest as GetTemplateRequest,
    GetTemplateResponse as GetTemplateResponse,
    InvalidTemplateParameters as InvalidTemplateParameters,
    LaunchFlexTemplateParameter as LaunchFlexTemplateParameter,
    LaunchFlexTemplateRequest as LaunchFlexTemplateRequest,
    LaunchFlexTemplateResponse as LaunchFlexTemplateResponse,
    LaunchTemplateParameters as LaunchTemplateParameters,
    LaunchTemplateRequest as LaunchTemplateRequest,
    LaunchTemplateResponse as LaunchTemplateResponse,
    ParameterMetadata as ParameterMetadata,
    ParameterType as ParameterType,
    RuntimeEnvironment as RuntimeEnvironment,
    RuntimeMetadata as RuntimeMetadata,
    SDKInfo as SDKInfo,
    TemplateMetadata as TemplateMetadata,
)