🙏*URGENT HELP NEEDED!*🙏 Hi. Dear Community! I was trying to run the steps of one workflow as container based ones. as described here. BTW when I was trying with the default images on that documentation page (e.x.

<http://ghcr.io/flyteorg/rawcontainers-python:v2|ghcr.io/flyteorg/rawcontainers-python:v2>

) it was ok with default inputs and outputs (e.x.

a:float, b:float, area:float, metadata:str

), BUT when I change them to FlyteFile or something else. it throws an error that "No Such File or Directory called

area

or

metadata

etc. I was thinking it's due to the image build. Is there anybody who has experience on this? or facing the same issues? Thank you.

Bear in mind that passing

FlyteDirectory

as input to RawContainer Tasks is not supported yet (it will be in the 1.14 release going out tomorrow)

For example.

--step definitiion--
save_to_csv = ContainerTask(
    name="save_to_csv_container",
    input_data_dir="/var/inputs",
    output_data_dir="/var/outputs",
    inputs=kwtypes(a=float, b=float),
    outputs=kwtypes(area=float, metadata=str),
    image="<http://ghcr.io/flyteorg/rawcontainers-python:v2|ghcr.io/flyteorg/rawcontainers-python:v2>",
    command=[
        "python",
        "main.py",
        "{{.inputs.a}}",
        "{{.inputs.b}}",
        "/var/outputs",
    ],
)
--main.py--
import sys

def write_output(output_dir, output_file, v):
    with open(f"{output_dir}/{output_file}", "w") as f:
        f.write(str(v))

def main(a, b, output_dir):
    write_output(output_dir, "area", str(float(5.0)))
    write_output(output_dir, "metadata", "[from python rawcontainer]")

if __name__ == "__main__":
    input_path = sys.argv[1]
    output_file = sys.argv[2]
    output_dir = sys.argv[3]

    main(input_path, output_file, output_dir)

This works but the below code doesn't work.

--step definitiion--
save_to_csv = ContainerTask(
    name="save_to_csv_container",
    input_data_dir="/var/inputs",
    output_data_dir="/var/outputs",
    inputs=kwtypes(a=str, b=float),                              # a changed to str type
    outputs=kwtypes(area=float, metadata=str),
    image="<http://ghcr.io/flyteorg/rawcontainers-python:v2|ghcr.io/flyteorg/rawcontainers-python:v2>",
    command=[
        "python",
        "main.py",
        "{{.inputs.a}}",
        "{{.inputs.b}}",
        "/var/outputs",
    ],
)
--main.py--
import sys

def write_output(output_dir, output_file, v):
    with open(f"{output_dir}/{output_file}", "w") as f:
        f.write(str(v))

def main(a, b, output_dir):
    write_output(output_dir, "area", str(float(5.0)))
    write_output(output_dir, "metadata", "[from python rawcontainer]")

if __name__ == "__main__":
    input_path = sys.argv[1]
    output_file = sys.argv[2]
    output_dir = sys.argv[3]

    main(input_path, output_file, output_dir)

The code might look weird since I removed some parts. Of course I passed the

a

input to both code as each variable type.

I’ll take a look today

To add your file that's not in the original image, you can use ImageSpec in image field. Like this:

ContainerTask(
    name="save_to_csv_container",
    input_data_dir="/var/inputs",
    output_data_dir="/var/outputs",
    inputs=kwtypes(a=float, b=float),
    outputs=kwtypes(area=float, metadata=str),
    image=ImageSpec(
        registry="localhost:30000",
        base_image="<http://ghcr.io/flyteorg/rawcontainers-python:v2|ghcr.io/flyteorg/rawcontainers-python:v2>",
        copy=["main.py"],
    )

Can you check if this script is working on your side or not?

sorry, none of those scripts work for me as is

'flytekit.types.file.file.FlyteFile'>. Expected a file, but
hello.txt is not a file.

You can add hello.txt file in the same folder with any content and try @average-finland-92144. That was just copying a simple file within python container which should work, but doesn't work.