@ancient-wolf-19325 is it possible to install flyte-core v1.15.x via helm charts in a single kubernetes namespace, so that both the control plane and task workflows run in the same kubernetes namespace? we also don’t want to install any cluster-wide resources, such as CRDs, ClusterRoles and ClusterRoleBindings

@ancient-wolf-19325 I have some tasks typed with a List[Union[str,datetime]] but running into this error, how would i type hint and pass lists around? or is passing lists around from task to task not supported Type of Generic List type is not supported, Transformer for type <class 'tuple'> is restricted currently

This message was deleted.

If any task fails how to get that output/status of that task? @ancient-wolf-19325

@ancient-wolf-19325 can I setup authentication on Flyte?

@ancient-wolf-19325 can you debug

exec /opt/conda/bin/pyflyte-fast-execute: exec format error

@ancient-wolf-19325 can you debug, in flyte logs but the task completes successfully

/opt/conda/lib/python3.11/site-packages/fsspec/asyn.py:76 in sync            │
│                                                                              │
│ ❱   76 │   │   raise RuntimeError("Loop is not running") 
RuntimeError: Loop is not running

@ancient-wolf-19325 how would i return the pod id from a current flyte task

@ancient-wolf-19325 How do I identify whether I am running in a container or locally? I have seen something like

is_container

or something in the documentation

@ancient-wolf-19325 in map_task, can we set an individual timeout and retry? We've run into scenarios where a hung pod(CPU constrained) should just be killed after some time. If we manually kill the pod it will spin up somewhere else and usually succeed

@ancient-wolf-19325 is there a way to set default pod labels in the Flyte core helm chart

@ancient-wolf-19325 how to implement Flyte control plane RBAC?

@ancient-wolf-19325 How can I setup default labels per Flyte domain in the flyte core helm chart

Hi @ancient-wolf-19325 How to replace my own image in pod spec config of task, dynamically while triggering workflow

@ancient-wolf-19325, Seeing below errors logs in flyte propeller pod when i trigger a execution W0729 093948.966687 1 warnings.go:70] metadata.finalizers: "flyte-finalizer": prefer a domain-qualified finalizer name to avoid accidental conflicts with other finalizer writers

@ancient-wolf-19325 how do i debug the error FlyteValidationException: USERValidationError error=Failed to bind output o0 for function src.workflows.deid.deidentify.read_batch: USERAssertionError error=File /tmp/flyte-0e8_buck/sandbox/local_flytekit/67b958d44442739b0c1ce0887b6bfae1/deid_source/deid_batch_ac36b72057604033826cf1b0f085713f.csv does not exis

@ancient-wolf-19325 how do I write a dataframe generated in a task into FlyteFile

@ancient-wolf-19325 Does flytekit version need to match the flyte core helm chart version?

@ancient-wolf-19325 how do I read a FlyteFile into a dataframe?

@ancient-wolf-19325 How do I setup an environment variable for all the tasks in a flyte workflow

@ancient-wolf-19325 how do you use the results from workflow A in workflow B

@ancient-wolf-19325 Does Flyte v1 support Typed dictionaries as ouputs

@ancient-wolf-19325 can you specify task dependency in flyte when there is no data dependency between them

@ancient-wolf-19325 I get

External sources are not supported in pyproject.toml

when I want to use Union's builder and I have pytorch in my pyproject.toml defined with

tool.uv.index

I’m building a data validation and cleaning tool. Users upload a dataset.csv and validation_rules.csv. I tried using LLMs, but hit rate limits due to large data and free plan limits. Now I’m exploring Pandera for static validation in Python

@ancient-wolf-19325 how do I use my own custom docker image in ImageSpec

@ancient-wolf-19325 can I set the status of a specific workflow to failed based on the output from a task?

@ancient-wolf-19325 I'm getting this error, why?

Running Execution on Remote.
╭─────────────────────────────── Traceback (most recent call last) ────────────────────────────────╮
│ /home/nkram/miniconda3/envs/union/lib/python3.10/site-packages/union/_usage.py:36 in             │
│ custom_invoke                                                                                    │
│                                                                                                  │
│    33 │   log_level = get_level_from_cli_verbosity(verbosity)                                    │
│    34 │   logger.setLevel(log_level)                                                             │
│    35 │   try:                                                                                   │
│ ❱  36 │   │   return Group.invoke(self, ctx)                                                     │
│    37 │   except Exception as e:                                                                 │
│    38 │   │   from union._exceptions import UnionRequireConfigException                          │
│    39                                                                                            │
│                                                                                                  │
│ /home/nkram/miniconda3/envs/union/lib/python3.10/concurrent/futures/_base.py:458 in result       │
│                                                                                                  │
│   455 │   │   │   │   if self._state in [CANCELLED, CANCELLED_AND_NOTIFIED]:                     │
│   456 │   │   │   │   │   raise CancelledError()                                                 │
│   457 │   │   │   │   elif self._state == FINISHED:                                              │
│ ❱ 458 │   │   │   │   │   return self.__get_result()                                             │
│   459 │   │   │   │   else:                                                                      │
│   460 │   │   │   │   │   raise TimeoutError()                                                   │
│   461 │   │   finally:                                                                           │
│                                                                                                  │
│ /home/nkram/miniconda3/envs/union/lib/python3.10/concurrent/futures/_base.py:403 in __get_result │
│                                                                                                  │
│   400 │   def __get_result(self):                                                                │
│   401 │   │   if self._exception:                                                                │
│   402 │   │   │   try:                                                                           │
│ ❱ 403 │   │   │   │   raise self._exception                                                      │
│   404 │   │   │   finally:                                                                       │
│   405 │   │   │   │   # Break a reference cycle with the exception in self._exception            │
│   406 │   │   │   │   self = None                                                                │
╰──────────────────────────────────────────────────────────────────────────────────────────────────╯
TypeError: expected string or bytes-like object

@ancient-wolf-19325 when changes in my code triggers flyte to increase workflow version?

@ancient-wolf-19325 i have a very basic question about flyte 2.0. I'm trying to a hello.py workflow locally by using the following command

flyte run --local hello.py main --n 10

but it is only performing a dry-run of it. How do i run it locally and get the output as well?