videoflow package
Subpackages
- videoflow.backends package
- Subpackages
- Submodules
- videoflow.backends.allocation module
AcceleratorAllocationBackendAcceleratorAllocationBackend.bindings()AcceleratorAllocationBackend.capabilities()AcceleratorAllocationBackend.inventory()AcceleratorAllocationBackend.observe()AcceleratorAllocationBackend.plan()AcceleratorAllocationBackend.reconcile()AcceleratorAllocationBackend.release()AcceleratorAllocationBackend.reserve()
ClaimObservationConstraintDeliveredGrantDeviceIdentityEXCLUSIVE_FEATURE_PAIRSFEATURE_DYNAMIC_MIGFeasiblePlanInfeasibleInventorySnapshotReleaseObservationWorkloadBindingsWorkloadRequestWorkloadRequest.constraintsWorkloadRequest.declared_peak_memory_bytesWorkloadRequest.device_countWorkloadRequest.elasticityWorkloadRequest.featuresWorkloadRequest.flow_idWorkloadRequest.hard_memory_limit_bytesWorkloadRequest.host_cpuWorkloadRequest.host_memoryWorkloadRequest.minimum_usable_memory_bytesWorkloadRequest.provenanceWorkloadRequest.reserved_memory_bytesWorkloadRequest.run_idWorkloadRequest.sharingWorkloadRequest.workload_id
allocation_rejections()
- videoflow.backends.capabilities module
ADMISSION_TIMEOUT_ENVAllocationCapabilitiesAllocationCapabilities.adapterAllocationCapabilities.admission_boundaryAllocationCapabilities.authorityAllocationCapabilities.cooperative_sharingAllocationCapabilities.elasticAllocationCapabilities.exclusive_deviceAllocationCapabilities.isolated_migAllocationCapabilities.memory_enforcementAllocationCapabilities.multi_deviceAllocationCapabilities.topology_verificationAllocationCapabilities.version_matrix
CompositionPlanEFFECT_AT_LEAST_ONCEExecutionCapabilitiesFlowRequirementsFlowRequirements.batchingFlowRequirements.effect_retention_secondsFlowRequirements.exactly_once_effectsFlowRequirements.execution_groupsFlowRequirements.from_dict()FlowRequirements.is_empty()FlowRequirements.priority_classFlowRequirements.profilesFlowRequirements.replay_horizon_secondsFlowRequirements.resourcesFlowRequirements.restart_safeFlowRequirements.rollout_policyFlowRequirements.sink_guaranteesFlowRequirements.to_dict()FlowRequirements.tolerated_failures
LEDGER_NONEMAX_STREAMS_ENVMessagingCapabilitiesMessagingCapabilities.adapterMessagingCapabilities.archiveMessagingCapabilities.control_shares_data_slotMessagingCapabilities.credit_resizableMessagingCapabilities.dedup_window_secondsMessagingCapabilities.durable_controlMessagingCapabilities.latest_per_keyMessagingCapabilities.max_consumersMessagingCapabilities.max_payload_bytesMessagingCapabilities.max_streamsMessagingCapabilities.mixed_retention_per_channelMessagingCapabilities.persistent_storageMessagingCapabilities.publication_ledgerMessagingCapabilities.recoverable_deliveryMessagingCapabilities.replication_factorMessagingCapabilities.retained_backlogMessagingCapabilities.version
PARENT_REPLICAS_ENVPROFILE_REQUESTS_ENVPayloadCapabilitiesProfileRequestRETENTION_LIMITSRUNTIME_STORE_ENVRuntimeCapabilitiesadmission_timeout_from_env()combined_limit()default_requirements()graph_limits_from_env()kubernetes_execution_capabilities()local_execution_capabilities()plan_composition()profile_for_edge()realtime_default_capabilities_note()requests_env()requests_from_env()
- videoflow.backends.faults module
- videoflow.backends.identity module
- videoflow.backends.messaging module
ChannelIdChannelObservationChannelSpecChannelSpec.dedup_window_secondsChannelSpec.idChannelSpec.max_age_secondsChannelSpec.max_bytesChannelSpec.max_msgsChannelSpec.overflowChannelSpec.owner_labelsChannelSpec.per_subject_limitsChannelSpec.persistenceChannelSpec.profileChannelSpec.replicasChannelSpec.required_subscriptionsChannelSpec.retention
CompletedDeliveryDeliveryTokenEnvelopeKIND_DATALeaseObservationMessagingBackendMessagingBackend.capabilities()MessagingBackend.close()MessagingBackend.ensure_channel()MessagingBackend.ensure_subscription()MessagingBackend.observe_ack_floor()MessagingBackend.observe_channel()MessagingBackend.observe_publication()MessagingBackend.observe_subscription()MessagingBackend.prefetched()MessagingBackend.publish()MessagingBackend.receive()MessagingBackend.receive_any()MessagingBackend.renew()MessagingBackend.set_admission()MessagingBackend.settle()MessagingBackend.shutdown()MessagingBackend.subscribe_control()MessagingBackend.supersede()
RetrySubscriptionIdSubscriptionObservationSubscriptionSpecTerminalVerifiedChannelVerifiedSubscription
- videoflow.backends.observation module
- videoflow.backends.outcomes module
- videoflow.backends.payload module
- videoflow.backends.payload_bridge module
- videoflow.backends.runtime module
CommitReceiptCompletionReceiptDEFAULT_PARTITION_LEASE_SECONDSDEFAULT_RECONCILE_INTERVAL_SECONDSFlowRuntimeFlowRuntime.aborted_parents()FlowRuntime.acquire_partition()FlowRuntime.attempts_for()FlowRuntime.capabilities()FlowRuntime.check_authority()FlowRuntime.checkpoint()FlowRuntime.clear_pending_handoff()FlowRuntime.commit_completion()FlowRuntime.completed_parents()FlowRuntime.completion_state()FlowRuntime.current_epoch()FlowRuntime.durable_shared()FlowRuntime.effect_seen()FlowRuntime.flow_idFlowRuntime.group_members()FlowRuntime.held_partition()FlowRuntime.intend_publication()FlowRuntime.key()FlowRuntime.lease_secondsFlowRuntime.mark_effect()FlowRuntime.nodeFlowRuntime.open_groups()FlowRuntime.outbox_entry()FlowRuntime.outbox_of()FlowRuntime.parent_replicasFlowRuntime.partition_id()FlowRuntime.pending_handoffs()FlowRuntime.persist_group()FlowRuntime.published_count()FlowRuntime.received_ids()FlowRuntime.record_attempt()FlowRuntime.record_pending_handoff()FlowRuntime.record_received()FlowRuntime.record_terminal()FlowRuntime.record_terminator()FlowRuntime.release_partition()FlowRuntime.renew_partition()FlowRuntime.replica_idFlowRuntime.resolve_publication()FlowRuntime.restore_checkpoint()FlowRuntime.run_idFlowRuntime.settle_group()FlowRuntime.source_epoch()FlowRuntime.storeFlowRuntime.terminal_entries()FlowRuntime.terminators()FlowRuntime.unresolved_publications()
LEASE_POLL_SECONDSOutboxEntryOwnershipTokenPendingHandoffRecoveryRecordRuntimeStoreTerminatorRecordclaim_replica_slot()group_identity()members_signature()partition_lease_from_env()reconcile_interval_from_env()replayable_trace_id()source_epoch_trace_id()store_shared_and_durable()
- videoflow.components package
- Submodules
- videoflow.components.descriptor module
ComponentDescriptorComponentDescriptor.all_inputs_accept()ComponentDescriptor.commandComponentDescriptor.cpu_requestComponentDescriptor.descriptionComponentDescriptor.deviceComponentDescriptor.finiteComponentDescriptor.from_dict()ComponentDescriptor.gpu_countComponentDescriptor.gpu_count_declaredComponentDescriptor.gpu_memory_gibComponentDescriptor.image_for()ComponentDescriptor.imagesComponentDescriptor.input_accepts()ComponentDescriptor.inputsComponentDescriptor.is_nativeComponentDescriptor.licenseComponentDescriptor.local_commandComponentDescriptor.memory_requestComponentDescriptor.nameComponentDescriptor.outputComponentDescriptor.params_schemaComponentDescriptor.partitionableComponentDescriptor.protocolComponentDescriptor.python_classComponentDescriptor.roleComponentDescriptor.singletonComponentDescriptor.validate_params()ComponentDescriptor.version
IO_ANYload_descriptor()
- videoflow.components.oci module
- videoflow.consumers package
- videoflow.core package
- Submodules
- videoflow.core.compiler module
NodeSpecNodeSpec.blob_readersNodeSpec.commandNodeSpec.component_refNodeSpec.deliveryNodeSpec.descriptorNodeSpec.device_typeNodeSpec.from_dict()NodeSpec.gpu_countNodeSpec.gpu_memory_gibNodeSpec.gpu_resource_nameNodeSpec.has_childrenNodeSpec.imageNodeSpec.is_finiteNodeSpec.is_nativeNodeSpec.is_remoteNodeSpec.join_policyNodeSpec.kindNodeSpec.nameNodeSpec.nb_tasksNodeSpec.node_classNodeSpec.paramsNodeSpec.parentsNodeSpec.partition_byNodeSpec.protocol_versionNodeSpec.to_dict()
batching_policies()blob_reader_ids()compile_flow()execution_groups()gpu_provenance()has_native_components()has_remote_components()parent_replicas()sink_guarantees()specs_from_tasks_data()validate_wire_compatibility()
- videoflow.core.constants module
- videoflow.core.context module
- videoflow.core.engine module
ExecutionEngineMessengerMessenger.STOP_AUTHORITY_LOSTMessenger.STOP_CONTROLMessenger.STOP_QUIESCEMessenger.ack_inputs()Messenger.check_for_termination()Messenger.checkpoint()Messenger.close()Messenger.fail_inputs()Messenger.last_input_info()Messenger.last_input_key()Messenger.pending_count()Messenger.pending_observation()Messenger.publish_abort()Messenger.publish_message()Messenger.publish_stop_signal()Messenger.quiesce()Messenger.receive_message()Messenger.restore_checkpoint()Messenger.resume_offset()Messenger.set_output_event_timestamp()Messenger.set_output_partition_key()Messenger.stop_reason()Messenger.take_drops()
- videoflow.core.errors module
ActiveRunConflictBrokerUnavailableCapabilityErrorClusterErrorConfigErrorDEFAULT_DISPOSITIONDecodeErrorDeviceErrorDiagnosticEXIT_USERFlowFailedFlowStalledGraphErrorIdentityCollisionIncompatibleProfileNodeContractErrorOwnershipConflictPOISONPartitionKeyErrorPoisonMessageProgressStalledResourceExhaustedResourceUnavailableSchemaErrorStaleAuthorityTransientFailureUnobservableStateUpstreamAbortedUpstreamUnavailableVideoflowEnvironmentErrorVideoflowErrorVideoflowRuntimeErrorVideoflowUserErrorWorkerFatalWorkerUnhealthyas_runtime_error()classify()error_to_dict()raise_for_diagnostics()register_classifier_for()register_error_classifier()registered_error_classifiers()
- videoflow.core.flow module
- videoflow.core.graph module
- videoflow.core.node module
- videoflow.core.policies module
- videoflow.core.provenance module
- videoflow.core.remote module
- videoflow.core.supervision module
- videoflow.core.task module
- videoflow.deploy package
- Submodules
- videoflow.deploy.admission module
PROBE_TIMEOUT_SECONDSadmit()enforce_admission()jetstream_capabilities()jetstream_capabilities_observed()local_dev_capabilities()parse_profile_requests()redis_payload_capabilities()redis_payload_capabilities_observed()requests_env()requests_from_env()requirements_for()run_stream_names()unknown_admission()verify_topology_shape()
- videoflow.deploy.allocation_dra module
DRA_GA_VERSIONDraAllocationBackendDraEnvironmentDraEnvironment.api_servedDraEnvironment.available_features()DraEnvironment.device_classesDraEnvironment.driverDraEnvironment.driver_featuresDraEnvironment.feature_gatesDraEnvironment.from_mapping()DraEnvironment.gate_enabled()DraEnvironment.kubernetes_versionDraEnvironment.to_mapping()DraEnvironment.unavailable_reasons()DraEnvironment.version
FEATURE_GATESGATE_SCHEDULEclaim_name_for()device_request()gate_stage()observe_environment()parse_version()render_bindings()
- videoflow.deploy.allocation_kubernetes module
CONSTRAINT_KEYSKubernetesAllocationBackendKubernetesAllocationBackend.bindings()KubernetesAllocationBackend.capabilities()KubernetesAllocationBackend.inventory()KubernetesAllocationBackend.managed_migKubernetesAllocationBackend.observe()KubernetesAllocationBackend.plan()KubernetesAllocationBackend.reconcile()KubernetesAllocationBackend.release()KubernetesAllocationBackend.reserve()
constraint_expressions()constraint_holds()requests_as_specs()snapshot_from_inventory()
- videoflow.deploy.allocation_local module
GRANT_ENVHEADROOM_ENVLocalAllocationBackendLocalAllocationBackend.bindings()LocalAllocationBackend.capabilities()LocalAllocationBackend.grant()LocalAllocationBackend.inventory()LocalAllocationBackend.observe()LocalAllocationBackend.plan()LocalAllocationBackend.policyLocalAllocationBackend.reconcile()LocalAllocationBackend.release()LocalAllocationBackend.reserve()
device_key()grant_from_env()host_memory_used_observed()snapshot_generation()
- videoflow.deploy.broker_profiles module
- videoflow.deploy.build module
- videoflow.deploy.cli module
- videoflow.deploy.cluster module
ClusterFlavorHandlerGpuAvailabilityactive_runs_observed()allocatable_gpus()classify_gfd_labels()classify_gpu_resource()combine_classifications()current_context()detect_cluster()dra_owned_nodes_observed()get_cluster_flavor()gpu_availability()gpu_inventory()gpu_inventory_observed()gpu_preflight()gpu_units_in_use()gpu_units_in_use_observed()hostpath_warning()is_registry_qualified()load_images()max_allocatable_gpus_per_node()nvidia_runtimeclass()refuse_concurrent_run()register_cluster_flavor()
- videoflow.deploy.compile module
- videoflow.deploy.gpu module
AllocationPlanAppliedGeometryDEFAULT_GPU_RESOURCEDraGpuExclusiveGpuGPU_OWNER_EPOCH_LABELGPU_OWNER_LABELGPU_POOL_LABELGpuStrategyIMPOSSIBLE_GPU_REQUESTMIG_APPLY_TIMEOUT_SECONDSMIG_CONFIGMAP_NAMEMIG_CONFIG_LABELMIG_CONFIG_NAME_ABSENTMIG_CONFIG_NAME_RESTORE_ANNOTATIONMIG_DISABLED_CONFIGMIG_ENTRY_ANNOTATIONMIG_LABEL_ABSENTMIG_MANAGER_ROLLOUT_TIMEOUT_SECONDSMIG_OPERATOR_DEFAULT_CONFIGMAPMIG_RESTORE_ANNOTATIONMIG_TOMBSTONE_ANNOTATIONMixGpuPACKING_EXACT_MAX_PODSPodPackingUNOBSERVABLE_GPU_STATEexpected_allocatable()flow_owner_value()geometry_advertised()get_gpu_mode()gpu_resource_provenance()pack_pod_claims()register_gpu_mode()registered_gpu_modes()resolve_gpu_resource()
- videoflow.deploy.images module
- videoflow.deploy.infra module
- videoflow.deploy.localinfra module
- videoflow.deploy.manifests module
MountProvisionSplitdelete_resources()dump_manifests()flow_name()flow_spec_configmap()gpu_demand()gpu_max_per_pod()gpu_pod_claims()headless_service()host_resources_for()k8s_name()nats_configmap()network_policy()node_configmap()parse_mounts()parse_pvc_mounts()pod_disruption_budget()pod_mounts()provision_init_job()render_manifests()rollout_strategy()run_name()scaled_object()split_provision_manifests()validate_gpu_specs()workload()
- videoflow.deploy.mig module
CardPlanGpuLayoutLayoutErrorMigProfileMigTableNodeInventoryNodeInventory.allocatableNodeInventory.card_countNodeInventory.dra_ownedNodeInventory.memory_gib_per_cardNodeInventory.mig_allowedNodeInventory.mig_configNodeInventory.mig_partitionedNodeInventory.nameNodeInventory.occupancy_knownNodeInventory.ownerNodeInventory.productNodeInventory.time_slicedNodeInventory.used_units
layout_to_mig_parted_config()mig_table_for_product()place()register_mig_table()solve_layout()
- videoflow.deploy.solution module
- videoflow.engines package
- videoflow.messaging package
- Submodules
- videoflow.messaging.grouping module
CollectEntryEnvelopeEntryEnvelopeEntry.blob_refEnvelopeEntry.event_tsEnvelopeEntry.flow_idEnvelopeEntry.from_decoded()EnvelopeEntry.is_stop_signalEnvelopeEntry.messageEnvelopeEntry.metadataEnvelopeEntry.parent_span_idEnvelopeEntry.producer_nameEnvelopeEntry.replica_idEnvelopeEntry.run_idEnvelopeEntry.seqEnvelopeEntry.span_idEnvelopeEntry.trace_idEnvelopeEntry.type
GroupAssemblerGroupEntryReadyGroupTimeGroupAssemblerTraceGroupAssemblermake_assembler()
- videoflow.messaging.jetstream_backend module
ACK_CONFIRM_SECONDSFETCH_TIMEOUT_SECONDSJetStreamMessagingBackendJetStreamMessagingBackend.budget_waits()JetStreamMessagingBackend.capabilities()JetStreamMessagingBackend.close()JetStreamMessagingBackend.connectedJetStreamMessagingBackend.ensure_channel()JetStreamMessagingBackend.ensure_subscription()JetStreamMessagingBackend.loopJetStreamMessagingBackend.mark_exhausted()JetStreamMessagingBackend.observe_ack_floor()JetStreamMessagingBackend.observe_channel()JetStreamMessagingBackend.observe_publication()JetStreamMessagingBackend.observe_subscription()JetStreamMessagingBackend.prefetched()JetStreamMessagingBackend.publish()JetStreamMessagingBackend.receive()JetStreamMessagingBackend.receive_any()JetStreamMessagingBackend.renew()JetStreamMessagingBackend.resident_bytes()JetStreamMessagingBackend.set_admission()JetStreamMessagingBackend.settle()JetStreamMessagingBackend.shutdown()JetStreamMessagingBackend.skipped()JetStreamMessagingBackend.start()JetStreamMessagingBackend.stop_receiving()JetStreamMessagingBackend.subject_for()JetStreamMessagingBackend.subscribe_control()JetStreamMessagingBackend.supersede()
channel_spec_for()consumer_credit()stream_config_for_spec()subscription_spec_for()
- videoflow.messaging.nats_messenger module
NATSMessengerNATSMessenger.ack_inputs()NATSMessenger.check_for_termination()NATSMessenger.checkpoint()NATSMessenger.close()NATSMessenger.fail_inputs()NATSMessenger.join_status()NATSMessenger.last_input_info()NATSMessenger.last_input_key()NATSMessenger.pending_count()NATSMessenger.pending_observation()NATSMessenger.publication_statsNATSMessenger.publish_abort()NATSMessenger.publish_message()NATSMessenger.publish_stop_signal()NATSMessenger.quiesce()NATSMessenger.receive_message()NATSMessenger.restore_checkpoint()NATSMessenger.resume_offset()NATSMessenger.set_output_event_timestamp()NATSMessenger.set_output_partition_key()NATSMessenger.stop_reason()NATSMessenger.subscription_status()NATSMessenger.take_drops()NATSMessenger.terminal_entries()
- videoflow.messaging.obligations module
- videoflow.messaging.topology module
DEFAULT_ITEM_CREDITDEFAULT_MAX_ACK_PENDINGDEFAULT_PREFETCHDEFAULT_READ_BACK_TIMEOUT_SECONDSDEFAULT_REALTIME_BUFFERDLQ_RETENTION_SECONDSLEGACY_BIND_CREDITVerifiedConsumerVerifiedStreamconnect_options_for()consumer_config_for()consumer_credit()control_subject_for()credit_admits()delete_run_streams()dlq_stream_config()dlq_stream_name()dlq_subject_filter()dlq_subject_for()durable_name_for()eos_anchor_config()eos_anchor_durable_name_for()eos_consumer_config()eos_durable_name_for()eos_subject_for()join_item_credit()max_deliver_for()observation_failure()partitioned_durable_name_for()profile_mismatches()provision_flow()provision_flow_connect()provision_flow_sync()quiet_error_cb()read_back_streams()read_back_streams_async()sanitize()stream_config_for()stream_label_selector()stream_name_for()subject_for()subject_owner()verify_channel_profiles()
- videoflow.processors package
- Subpackages
- videoflow.processors.vision package
- Submodules
- videoflow.processors.vision.annotators module
- videoflow.processors.vision.counters module
- videoflow.processors.vision.detectors module
- videoflow.processors.vision.pose module
- videoflow.processors.vision.segmentation module
- videoflow.processors.vision.trackers module
- videoflow.processors.vision.transformers module
- videoflow.processors.vision package
- Submodules
- videoflow.processors.aggregators module
- videoflow.processors.basic module
- Subpackages
- videoflow.producers package
- videoflow.runtime package
- Submodules
- videoflow.runtime.assetcheck module
- videoflow.runtime.gpucheck module
- videoflow.runtime.health module
DROP_REASON_POISONHealthServerHealthStateInstrumentedMessengerInstrumentedMessenger.ack_inputs()InstrumentedMessenger.check_for_termination()InstrumentedMessenger.close()InstrumentedMessenger.fail_inputs()InstrumentedMessenger.last_input_info()InstrumentedMessenger.last_input_key()InstrumentedMessenger.pending_count()InstrumentedMessenger.pending_observation()InstrumentedMessenger.publish_abort()InstrumentedMessenger.publish_message()InstrumentedMessenger.publish_stop_signal()InstrumentedMessenger.quiesce()InstrumentedMessenger.receive_message()InstrumentedMessenger.set_output_event_timestamp()InstrumentedMessenger.set_output_partition_key()InstrumentedMessenger.stop_reason()
LATENCY_BUCKETS_SECONDSThroughputSnapshotparse_histogram()quantile_bounds()
- videoflow.runtime.idempotency module
- videoflow.runtime.logging_config module
- videoflow.runtime.provision module
- videoflow.runtime.redis_runtime_store module
- videoflow.runtime.runtime_stores module
- videoflow.runtime.scaling module
CAPACITY_ADMITTEDCapacityDecisionDEFAULT_TARGET_LAG_PER_REPLICADEMAND_UNKNOWNDEMAND_WITHIN_OBJECTIVEDemandDecisionJOB_REJECTIONJOIN_REJECTIONMISSING_OBSERVATIONPARTITION_INTENT_REJECTIONParentDemandRateDecisionRateObjectiveThroughputSampleadmit_autoscaling()job_autoscaling_error()observe_demand()observe_rate_demand()parent_lag()reconcile_capacity()replicas_for_lag()scaling_rejections()throughput_sample()validate_rate_objective()validate_scaling_rule()
- videoflow.runtime.watchdog module
- videoflow.runtime.worker module
- videoflow.utils package
- videoflow.v1 package
- videoflow.wire package
- Submodules
- videoflow.wire.redis_payload_store module
- Why this module exists
- Keys (
BLOB-13) - Lifecycle (
BLOB-14) - Typed reads (
BLOB-15) - redis-py facts this module relies on (redis 8.0.1,
.venv/.../redis/) COUNTER_KEY_PREFIXDEFAULT_ORPHAN_GRACE_SECONDSINTENT_PREFIXMAX_OBJECT_BYTESRedisPayloadStoreRedisPayloadStore.acquire_obligation()RedisPayloadStore.capabilities()RedisPayloadStore.clientRedisPayloadStore.inventory()RedisPayloadStore.put()RedisPayloadStore.read()RedisPayloadStore.reconcile()RedisPayloadStore.ref_for_key()RedisPayloadStore.release_obligation()RedisPayloadStore.renew_obligation()
SCAN_COUNTSTORE_IDTRANSACTION_RETRIESblob_key_of()counter_key()metadata_key()obligation_key()redis_capabilities_observed()
- videoflow.wire.serialization module
BlobStoreCOMPATIBLE_ENVELOPE_VERSIONSDEFAULT_BLOB_TTL_SECONDSDEFAULT_ENVELOPE_VERSIONEMITTABLE_ENVELOPE_VERSIONSENVELOPE_OVERHEAD_BYTESMAX_ERROR_TEXT_BYTESMAX_INLINE_PAYLOAD_BYTESMSG_TYPE_DATAMSG_TYPE_TERMINATORSPAYLOAD_ENTRY_POINT_GROUPPAYLOAD_TENSORRawPayloadRedisBlobStoredecode_envelope()derive_message_id()encode_envelope()error_from_proto()error_to_proto()hydrate_message()make_blob_store()peek_envelope()register_blob_store()register_payload_encoder()register_payload_type()registered_blob_store_schemes()safe_inline_threshold()serialized_payload_size()
Submodules
videoflow.cli module
Moved to videoflow.deploy.cli.
This module remains as a permanent compatibility shim: the videoflow
console script resolves videoflow.cli:main, and an installed entry point
outlives the source tree it was generated from. Do not add code — edit
videoflow/deploy/cli.py instead.
videoflow.compile module
Moved to videoflow.deploy.compile.
This module remains as a permanent compatibility shim: videoflow deploy
spawns python -m videoflow.compile inside the solution image, so the host
CLI and the image can be different videoflow versions in either direction and
the old path must keep resolving. Do not add code — edit
videoflow/deploy/compile.py instead.
videoflow.provision module
Moved to videoflow.runtime.provision.
This module remains as a permanent compatibility shim: python -m
videoflow.provision is rendered into the provision init Job of every deployed
flow, and those manifests may already be applied in a cluster. Do not add code
— edit videoflow/runtime/provision.py instead.
videoflow.serialization module
Moved to videoflow.wire.serialization.
This module remains as a permanent compatibility shim: the wire format is the one
thing a message outlives its producer on, so external importers may have pinned this
module path, and it must keep resolving to the wire codec. Do not add code — edit
videoflow/wire/serialization.py instead.
videoflow.version module
videoflow.worker module
Moved to videoflow.runtime.worker.
This module remains as a permanent compatibility shim, and is the most frozen
path in the package: python -m videoflow.worker is the ENTRYPOINT baked into
the published base images, inherited by every contrib component image, and
spawned by the local engine. Already-built images cannot be retargeted. Do not
add code — edit videoflow/runtime/worker.py instead.