flytekit.bin.entrypoint
| Property |
Type |
Description |
FLYTE_FAIL_ON_ERROR |
str |
|
RUNTIME_PACKAGES_ENV_NAME |
str |
|
SERIALIZED_CONTEXT_ENV_VAR |
str |
|
def get_container_error_timestamp(
e: typing.Optional[Exception] = None,
) -> google.protobuf.timestamp_pb2.Timestamp
Get timestamp for ContainerError.
If a flyte exception is passed, use its timestamp, otherwise, use the current time.
| Parameter |
Type |
Description |
e |
typing.Optional[Exception] |
Exception that has occurred. Optional. |
Returns: Timestamp to be reported in ContainerError
def get_one_of(
*args,
) -> str
Helper function to iterate through a series of different environment variables. This function exists because for
some settings reference multiple environment variables for legacy reasons.
| Parameter |
Type |
Description |
*args |
|
List of environment variables to look for. |
Returns: The first defined value in the environment, or an empty string if nothing is found.
def get_traceback_str(
e: Exception,
) -> str
| Parameter |
Type |
Description |
e |
Exception |
|
def get_version_message()
def normalize_inputs(
raw_output_data_prefix: typing.Optional[str],
checkpoint_path: typing.Optional[str],
prev_checkpoint: typing.Optional[str],
)
| Parameter |
Type |
Description |
raw_output_data_prefix |
typing.Optional[str] |
|
checkpoint_path |
typing.Optional[str] |
|
prev_checkpoint |
typing.Optional[str] |
|
def setup_execution(
raw_output_data_prefix: str,
output_metadata_prefix: typing.Optional[str] = None,
checkpoint_path: typing.Optional[str] = None,
prev_checkpoint: typing.Optional[str] = None,
dynamic_addl_distro: typing.Optional[str] = None,
dynamic_dest_dir: typing.Optional[str] = None,
)
| Parameter |
Type |
Description |
raw_output_data_prefix |
str |
Where to write offloaded data (files, directories, dataframes). |
output_metadata_prefix |
typing.Optional[str] |
Where to write primitive outputs. |
checkpoint_path |
typing.Optional[str] |
|
prev_checkpoint |
typing.Optional[str] |
|
dynamic_addl_distro |
typing.Optional[str] |
Works in concert with the other dynamic arg. If present, indicates that if a dynamic task were to run, it should set fast serialize to true and use these values in FastSerializationSettings |
dynamic_dest_dir |
typing.Optional[str] |
See above. |
