#6337 [BUG] Weird exception Streaming API of FlyteFile/FlyteDirectory Issue created by cjidboon94 ### Describe the bug While trying out the streaming API for files and directories to speed up some parts of my code, I ran into the following exception:

Original exception: Invalid variable type: value should be str, int or float, got FlyteContext(file_access=<flytekit.core.data_persistence.FileAccessProvider object at 0x795cc4248f70>, level=4, flyte_client=None, compilation_state=None, execution_state=ExecutionState(mode=<Mode.TASK_EXECUTION: 1>, working_dir=PosixPath('/tmp/flytecphsguxb/local_flytekit'), engine_dir='/tmp/flytecphsguxb/local_flytekit/engine_dir', branch_eval_mode=None, user_space_params=ExecutionParameters(execution_date=2025-03-11 18:21:01.821699+00:00, stats=<flytekit.interfaces.stats.taggable.TaggableStats object at 0x795cc42488e0>, tmp_dir=/tmp/flyte-y7i7t51b/sandbox/local_flytekit/8fa767fd4226dc3f5ca402270b4cbe66, execution_id=Flyte Serialized object (WorkflowExecutionIdentifier):
      project: flytesnacks
      domain: development
      name: ankpjf7p5bjfcfd5ts76,  checkpoint=<flytekit.core.checkpointer.SyncCheckpoint object at 0x795cc4248070>,, decks=[], raw_output_prefix=<gs://xxxx-flyte/data/k0/ankpjf7p5bjfcfd5ts76-n2-0-n2-n0-0-n0-0>, task_id=TASK:flytesnacks:development:raw_workflow.xxx.main.xxx_task:fDRVXJU6bMjLL3los9Bc2w, output_metadata_prefix=<gs://xxx-flyte/metadata/propeller/flytesnacks-development-ankpjf7p5bjfcfd5ts76/n2/data/0/n2-n0/0/n0/0>, enable_deck=False)), serialization_settings=SerializationSettings(image_config=ImageConfig(default_image=None, images=[]), project='flytesnacks', domain='development', version='fDRVXJU6bMjLL3los9Bc2w', env=None, git_repo=None, python_interpreter='/opt/venv/bin/python3', flytekit_virtualenv_root='/opt/venv', fast_serialization_settings=FastSerializationSettings(enabled=True, destination_dir='.', distribution_location='<gs://xxx-flyte/flytesnacks/development/C2J4ETIZP3J2Y67M7CMS3MJEUQ======/fastb1cd8a8ec0c0cffdd1174f7388e3ff64.tar.gz>'), source_root=None), in_a_condition=False, origin_stackframe=<FrameSummary file /usr/local/lib/python3.10/site-packages/flytekit/core/base_task.py, line 732 in dispatch_execute>, output_metadata_tracker=OutputMetadataTracker(output_metadata={}), worker_queue=None) of type <class 'flytekit.core.context_manager.FlyteContext'>

Full stacktrace:

File "/xxx_workflow/xxx/main.py", line 23, in convert
        _, ext= os.path.splitext(raw_file)
      File "/usr/local/lib/python3.10/posixpath.py", line 118, in splitext
        p = os.fspath(p)
      File "/usr/local/lib/python3.10/site-packages/flytekit/types/file/file.py", line 356, in __fspath__
        self._downloader()
      File "/usr/local/lib/python3.10/site-packages/flytekit/utils/asyn.py", line 113, in wrapped
        return self.run_sync(coro_func, *args, **kwargs)
      File "/usr/local/lib/python3.10/site-packages/flytekit/utils/asyn.py", line 106, in run_sync
        return self._runner_map[name].run(coro)
      File "/usr/local/lib/python3.10/site-packages/flytekit/utils/asyn.py", line 85, in run
        res = fut.result(None)
      File "/usr/local/lib/python3.10/concurrent/futures/_base.py", line 458, in result
        return self.__get_result()
      File "/usr/local/lib/python3.10/concurrent/futures/_base.py", line 403, in __get_result
        raise self._exception
      File "/usr/local/lib/python3.10/site-packages/flytekit/core/data_persistence.py", line 628, in async_get_data
        raise FlyteDownloadDataException(
    flytekit.exceptions.system.FlyteDownloadDataException: SYSTEM:DownloadDataError: error=Failed to get data from <gs://xxx-flyte/data/lx/ankpjf7p5bjfcfd5ts76-n0-0-n0-0/fd421400cf5b1111051dffd6b51b5349/xxx> to /tmp/flytecphsguxb/local_flytekit/2f5c90639bde398a2a90c8c7a144ded2/xxx (recursive=False)

This happened in image where

flytekit

version was

1.15.2

installed. I then had an older image where

flytekit

version

1.13.7

was installed and there it seemed to work fine. ### Expected behavior That the file would be downloaded/streamed at access and my code would just move forward. ### Additional context to reproduce Minimal code snippet to reproduce it on flytekit 1.15.x import os from flytekit import task from flytekit.types.directory import FlyteDirectory from flytekit.types.file import FlyteFile @task def process_data(data_dir: FlyteDirectory): for (base, filepath) in data_dir.crawl(): raw_file = FlyteFile(os.path.join(base, filepath) _, ext = os.path.splitext(raw_file) The same example works with flytekit 1.13.7. So I assume something changed between the two versions. ### Screenshots No response ### Are you sure this issue hasn't been raised already? • Yes ### Have you read the Code of Conduct? • Yes flyteorg/flyte