Index

A

Argument (class in workflow_utils.configparser) argument() (workflow_utils.workflow_io.WorkflowIo method) argument_type() (workflow_utils.workflow_io.WorkflowIo method)

ArgumentType (class in workflow_utils.configparser) arrow() (workflow_utils.input_output.In.Dataset method) (workflow_utils.input_output.In.File method) arrow_value() (workflow_utils.workflow_io.WorkflowIo method)

B

BaseOutputTransport (class in workflow_utils.input_output)

bytes() (workflow_utils.input_output.In.File method)

C

cast_categorical() (workflow_utils.dataset.Dataset method) concat_datasets() (in module workflow_utils.dataset) consumer_name (workflow_utils.datastream.NatsMetadata attribute) content_type (workflow_utils.input_output.In.File attribute) (workflow_utils.input_output.Out.Arrow attribute) (workflow_utils.input_output.Out.Bytes attribute) (workflow_utils.input_output.Out.CSV attribute) (workflow_utils.input_output.Out.File attribute) (workflow_utils.input_output.Out.Text attribute) (workflow_utils.input_output.Out.XLSX attribute) (workflow_utils.workflow_io.PackageOptions attribute)

contents (workflow_utils.configparser.PackageInfo attribute) contextualize() (workflow_utils.dataset.Dataset method) contextualize_arrow_table() (workflow_utils.dataset.Dataset method) contextualize_df() (workflow_utils.dataset.Dataset method) contextualize_schema() (workflow_utils.dataset.Dataset method) copy() (workflow_utils.dataset.Dataset method) copy_metadata() (workflow_utils.dataset.Dataset method) create_metadata_frame() (workflow_utils.dataset.Dataset method)

D

Dataset (class in workflow_utils.dataset) DATASET (workflow_utils.configparser.ArgumentType attribute) (workflow_utils.configparser.ReturnType attribute) dataset() (workflow_utils.input_output.In.Dataset method) (workflow_utils.input_output.In.File method)

dataset_id (workflow_utils.workflow_io.DatasetFetch attribute) (workflow_utils.workflow_io.PackageItemFetch attribute) dataset_value() (workflow_utils.workflow_io.WorkflowIo method) DatasetFetch (class in workflow_utils.workflow_io) DataStream (class in workflow_utils.datastream)

E

ENUM (workflow_utils.configparser.ArgumentType attribute)

enum_value() (workflow_utils.workflow_io.WorkflowIo method)

F

field_name (workflow_utils.input_output.PackageUploader attribute) FILE (workflow_utils.configparser.ArgumentType attribute) (workflow_utils.configparser.ReturnType attribute) file_content() (workflow_utils.workflow_io.WorkflowIo method) file_like() (workflow_utils.workflow_io.WorkflowIo method) file_name (workflow_utils.input_output.In.File attribute)

flight_path (workflow_utils.workflow_io.PackageOptions attribute) FLOAT (workflow_utils.configparser.ArgumentType attribute) float_value() (workflow_utils.workflow_io.WorkflowIo method) format (workflow_utils.workflow_io.PackageOptions attribute) from_arrow() (workflow_utils.dataset.Dataset class method) from_arrow_file() (workflow_utils.dataset.Dataset class method) from_filelike() (workflow_utils.dataset.Dataset class method)

G

generate_primary_id() (workflow_utils.dataset.Dataset method) get_age_column() (workflow_utils.dataset.Dataset method) get_batch_id_column() (workflow_utils.dataset.Dataset method) get_categorical_columns() (workflow_utils.dataset.Dataset method) get_columns() (workflow_utils.dataset.Dataset method) get_data_columns() (workflow_utils.dataset.Dataset method) get_flight_ticket() (workflow_utils.workflow_io.DatasetFetch method) (workflow_utils.workflow_io.PackageItemFetch method)

get_messages() (workflow_utils.datastream.DataStream method) get_non_data_columns() (workflow_utils.dataset.Dataset method) get_payload_data() (workflow_utils.dataset.Dataset method) get_phase_id_column() (workflow_utils.dataset.Dataset method) get_primary_id_column() (workflow_utils.dataset.Dataset method) get_secondary_id_columns() (workflow_utils.dataset.Dataset method) get_text_columns() (workflow_utils.dataset.Dataset method)

I

id (workflow_utils.configparser.PackageItemInfo attribute) In (class in workflow_utils.input_output) In.Dataset (class in workflow_utils.input_output) In.Datasets (class in workflow_utils.input_output) In.Enum (class in workflow_utils.input_output) In.File (class in workflow_utils.input_output) In.Files (class in workflow_utils.input_output)

In.JSON (class in workflow_utils.input_output) In.Secret (class in workflow_utils.input_output) In.Stream (class in workflow_utils.input_output) inbox_prefix (workflow_utils.datastream.NatsMetadata attribute) init_members() (workflow_utils.input_output.BaseOutputTransport method) int_value() (workflow_utils.workflow_io.WorkflowIo method) INTEGER (workflow_utils.configparser.ArgumentType attribute) iter() (workflow_utils.input_output.Package method)

J

jet_stream_name (workflow_utils.datastream.NatsMetadata attribute) JSON (workflow_utils.configparser.ArgumentType attribute)

json() (workflow_utils.input_output.In.File method) json_value() (workflow_utils.workflow_io.WorkflowIo method) jwt (workflow_utils.datastream.NatsMetadata attribute)

L

load() (workflow_utils.input_output.PackageItem method)

M

Message (class in workflow_utils.datastream) mime_type (workflow_utils.configparser.PackageItemInfo attribute) (workflow_utils.input_output.PackageItem attribute) model_config (workflow_utils.configparser.PackageInfo attribute) (workflow_utils.configparser.PackageItemInfo attribute)

module workflow_utils.configparser workflow_utils.dataset workflow_utils.datastream workflow_utils.input_output workflow_utils.workflow_io

N

name (workflow_utils.configparser.Argument attribute) (workflow_utils.configparser.PackageItemInfo attribute) (workflow_utils.configparser.Return attribute) (workflow_utils.input_output.Out.Dataset attribute) (workflow_utils.input_output.Out.File attribute) (workflow_utils.input_output.PackageItem attribute) (workflow_utils.workflow_io.PackageOptions attribute)

NatsMetadata (class in workflow_utils.datastream) num_inputs() (workflow_utils.workflow_io.WorkflowIo method) num_outputs() (workflow_utils.workflow_io.WorkflowIo method)

O

order (workflow_utils.configparser.PackageItemInfo attribute) (workflow_utils.input_output.PackageItem attribute) Out (class in workflow_utils.input_output) Out.Arrow (class in workflow_utils.input_output) Out.Bytes (class in workflow_utils.input_output) Out.CSV (class in workflow_utils.input_output)

Out.Dataset (class in workflow_utils.input_output) Out.Datasets (class in workflow_utils.input_output) Out.File (class in workflow_utils.input_output) Out.Files (class in workflow_utils.input_output) Out.Stream (class in workflow_utils.input_output) Out.Text (class in workflow_utils.input_output) Out.XLSX (class in workflow_utils.input_output)

P

Package (class in workflow_utils.input_output) PACKAGE (workflow_utils.configparser.ArgumentType attribute) (workflow_utils.configparser.ReturnType attribute) package_id (workflow_utils.configparser.PackageInfo attribute) PackageInfo (class in workflow_utils.configparser) PackageItem (class in workflow_utils.input_output) PackageItemFetch (class in workflow_utils.workflow_io) PackageItemInfo (class in workflow_utils.configparser) PackageOptions (class in workflow_utils.workflow_io) PackageUploader (class in workflow_utils.input_output) pandas() (workflow_utils.input_output.In.Dataset method) (workflow_utils.input_output.In.File method) pandas_value() (workflow_utils.workflow_io.WorkflowIo method) parameter (workflow_utils.input_output.PackageUploader attribute) parse_arrow_table() (in module workflow_utils.dataset) parse_roles() (in module workflow_utils.dataset) (workflow_utils.dataset.Dataset method) polars() (workflow_utils.input_output.In.Dataset method) (workflow_utils.input_output.In.File method)

polars_value() (workflow_utils.workflow_io.WorkflowIo method) position (workflow_utils.configparser.Argument attribute) (workflow_utils.configparser.PackageItemInfo attribute) (workflow_utils.configparser.Return attribute) (workflow_utils.input_output.PackageItem attribute) presigned_base_url (workflow_utils.input_output.Package attribute) presigned_id (workflow_utils.configparser.PackageInfo attribute) (workflow_utils.configparser.PackageItemInfo attribute) (workflow_utils.workflow_io.PackageItemFetch attribute) presigned_uris (workflow_utils.configparser.Argument attribute) (workflow_utils.configparser.Return attribute) prio (workflow_utils.configparser.PackageItemInfo attribute) (workflow_utils.input_output.Out.Dataset attribute) (workflow_utils.input_output.Out.File attribute) (workflow_utils.input_output.PackageItem attribute) (workflow_utils.workflow_io.PackageOptions attribute) publish_message() (workflow_utils.datastream.DataStream method) python_module() (workflow_utils.workflow_io.WorkflowIo method)

Q

query_params (workflow_utils.workflow_io.PackageOptions attribute)

QUEUE (workflow_utils.configparser.ArgumentType attribute) (workflow_utils.configparser.ReturnType attribute)

R

read_vector() (workflow_utils.workflow_io.WorkflowIo method) remove_metadata() (workflow_utils.dataset.Dataset method) remove_role_metadata() (workflow_utils.dataset.Dataset method) Return (class in workflow_utils.configparser) return_arrow() (workflow_utils.workflow_io.WorkflowIo method) return_bytes() (workflow_utils.workflow_io.WorkflowIo method) return_csv() (workflow_utils.workflow_io.WorkflowIo method)

return_dataset() (workflow_utils.workflow_io.WorkflowIo method) return_excel() (workflow_utils.workflow_io.WorkflowIo method) return_file() (workflow_utils.workflow_io.WorkflowIo method) return_stream() (workflow_utils.workflow_io.WorkflowIo method) return_type() (workflow_utils.workflow_io.WorkflowIo method) return_vector() (workflow_utils.workflow_io.WorkflowIo method) ReturnType (class in workflow_utils.configparser) reveal() (workflow_utils.input_output.In.Secret method)

S

schema() (workflow_utils.datastream.Message method) SECRET (workflow_utils.configparser.ArgumentType attribute) seed (workflow_utils.datastream.NatsMetadata attribute) server_url (workflow_utils.datastream.NatsMetadata attribute) set_role() (workflow_utils.dataset.Dataset method)

size (workflow_utils.configparser.PackageItemInfo attribute) (workflow_utils.input_output.PackageItem attribute) stream_values() (workflow_utils.workflow_io.WorkflowIo method) STRING (workflow_utils.configparser.ArgumentType attribute) string_value() (workflow_utils.workflow_io.WorkflowIo method)

T

text() (workflow_utils.input_output.In.File method) to_binary() (workflow_utils.datastream.Message method) to_pandas() (workflow_utils.datastream.Message method) to_polars() (workflow_utils.datastream.Message method) to_table() (workflow_utils.dataset.Dataset method)

type (workflow_utils.configparser.Argument attribute) (workflow_utils.configparser.PackageItemInfo attribute) (workflow_utils.configparser.Return attribute) (workflow_utils.input_output.PackageItem attribute) (workflow_utils.workflow_io.PackageOptions attribute)

U

UNKNOWN (workflow_utils.configparser.ArgumentType attribute) (workflow_utils.configparser.ReturnType attribute) update_after_removal() (workflow_utils.dataset.Dataset method) update_roles() (workflow_utils.dataset.Dataset method) Upload (class in workflow_utils.input_output) upload() (workflow_utils.input_output.Upload.Dataset method) (workflow_utils.input_output.Upload.Datasets method) (workflow_utils.input_output.Upload.File method) (workflow_utils.input_output.Upload.Files method) Upload.Dataset (class in workflow_utils.input_output) Upload.Datasets (class in workflow_utils.input_output)

Upload.File (class in workflow_utils.input_output) Upload.Files (class in workflow_utils.input_output) upload_dataset() (workflow_utils.input_output.PackageUploader method) upload_file() (workflow_utils.input_output.PackageUploader method) uri_flight (workflow_utils.configparser.PackageItemInfo attribute) (workflow_utils.workflow_io.DatasetFetch attribute) (workflow_utils.workflow_io.PackageItemFetch attribute) uri_rest (workflow_utils.configparser.PackageItemInfo attribute) (workflow_utils.workflow_io.DatasetFetch attribute) (workflow_utils.workflow_io.PackageItemFetch attribute) usp_file() (workflow_utils.workflow_io.WorkflowIo method)

V

value (workflow_utils.configparser.Argument attribute) (workflow_utils.configparser.Return attribute) (workflow_utils.input_output.In.Dataset attribute) (workflow_utils.input_output.In.Enum attribute) (workflow_utils.input_output.In.JSON attribute) (workflow_utils.input_output.Out.Arrow attribute) (workflow_utils.input_output.Out.Bytes attribute) (workflow_utils.input_output.Out.CSV attribute) (workflow_utils.input_output.Out.Dataset attribute) (workflow_utils.input_output.Out.File attribute) (workflow_utils.input_output.Out.Stream attribute) (workflow_utils.input_output.Out.Text attribute) (workflow_utils.input_output.Out.XLSX attribute) (workflow_utils.input_output.Package attribute)

value() (workflow_utils.workflow_io.WorkflowIo method) values (workflow_utils.input_output.Out.Datasets attribute) (workflow_utils.input_output.Out.Files attribute) values() (workflow_utils.input_output.In.Stream method) version_id (workflow_utils.configparser.PackageItemInfo attribute) version_number (workflow_utils.configparser.PackageItemInfo attribute) (workflow_utils.input_output.PackageItem attribute)

W

wio (workflow_utils.input_output.PackageUploader attribute) workflow_utils.configparser module workflow_utils.dataset module workflow_utils.datastream module

workflow_utils.input_output module workflow_utils.workflow_io module WorkflowIo (class in workflow_utils.workflow_io)