Failed to upload files to Pipelines

[panicpotatoe]

hi,

I'm trying to launch the very first steps with FATE. I succeeded to:

• started Docker Container
• successfully ran the test script with no 0 failed case bash ./python/federatedml/test/run_test.sh
• started server bash ./python/federatedml/test/run_test.sh
• started pipeline pipeline init --ip 127.0.0.1 --port 9380
• then I tried to upload data to pipeline and run the test, but failed

here is the code I used to upload files (from your README file)
python3 FATE-master/examples/pipeline/demo/pipeline-upload.py --base /home/fatepipeline-evn/FATE-master

and here is the error log

2021-07-01 11:26:00.035831: W tensorflow/stream_executor/platform/default/dso_loader.cc:64] Could not load dynamic library 'libcudart.so.11.0'; dlerror: libcudart.so.11.0: cannot open shared object file: No such file or directory
2021-07-01 11:26:00.035874: I tensorflow/stream_executor/cuda/cudart_stub.cc:29] Ignore above cudart dlerror if you do not have a GPU set up on your machine.
2021-07-01 11:26:00.939 | ERROR    | __main__:main:66 - An error has been caught in function 'main', process 'MainProcess' (17528), thread 'MainThread' (140634439550784):
Traceback (most recent call last):

  File "/home/fatepipeline-evn/lib/python3.8/site-packages/pipeline/utils/invoker/job_submitter.py", line 105, in upload_data
    raise ValueError

ValueError


During handling of the above exception, another exception occurred:


Traceback (most recent call last):

  File "FATE-master/examples/pipeline/demo/pipeline-upload.py", line 76, in <module>
    main(args.base)
    │    │    └ '/home/fatepipeline-evn/FATE-master'
    │    └ Namespace(base='/home/fatepipeline-evn/FATE-master')
    └ <function main at 0x7fe801583dc0>

> File "FATE-master/examples/pipeline/demo/pipeline-upload.py", line 66, in main
    pipeline_upload.upload(work_mode=work_mode, backend=backend, drop=1)
    │               │                │                  └ <Backend.EGGROLL: 0>
    │               │                └ <WorkMode.STANDALONE: 0>
    │               └ <function PipeLine.upload at 0x7fe7a5f0a310>
    └ <pipeline.backend.pipeline.PipeLine object at 0x7fe7a5f0edc0>

  File "/home/fatepipeline-evn/lib/python3.8/site-packages/pipeline/backend/pipeline.py", line 508, in upload
    self._train_job_id, detail_info = self._job_invoker.upload_data(upload_conf, int(drop))
    │    │                            │    │            │           │                └ 1
    │    │                            │    │            │           └ {'file': '/home/fatepipeline-evn/FATE-master/examples/data/breast_hetero_guest.csv', 'table_name': 'breast...
    │    │                            │    │            └ <function JobInvoker.upload_data at 0x7fe7a5efd940>
    │    │                            │    └ <pipeline.utils.invoker.job_submitter.JobInvoker object at 0x7fe7a5f0eb20>
    │    │                            └ <pipeline.backend.pipeline.PipeLine object at 0x7fe7a5f0edc0>
    │    └ None
    └ <pipeline.backend.pipeline.PipeLine object at 0x7fe7a5f0edc0>
  File "/home/fatepipeline-evn/lib/python3.8/site-packages/pipeline/utils/invoker/job_submitter.py", line 113, in upload_data
    raise ValueError("job submit failed, err msg: {}".format(result))
                                                             └ {'retcode': 100, 'retmsg': 'Connection refused, Please check if the fate flow service is started'}

ValueError: job submit failed, err msg: {'retcode': 100, 'retmsg': 'Connection refused, Please check if the fate flow service is started'}
Traceback (most recent call last):
  File "/home/fatepipeline-evn/lib/python3.8/site-packages/pipeline/utils/invoker/job_submitter.py", line 105, in upload_data
    raise ValueError
ValueError

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "FATE-master/examples/pipeline/demo/pipeline-upload.py", line 76, in <module>
    main(args.base)
  File "FATE-master/examples/pipeline/demo/pipeline-upload.py", line 66, in main
    pipeline_upload.upload(work_mode=work_mode, backend=backend, drop=1)
  File "/home/fatepipeline-evn/lib/python3.8/site-packages/loguru/_logger.py", line 1220, in catch_wrapper
    return function(*args, **kwargs)
  File "/home/fatepipeline-evn/lib/python3.8/site-packages/pipeline/backend/pipeline.py", line 508, in upload
    self._train_job_id, detail_info = self._job_invoker.upload_data(upload_conf, int(drop))
  File "/home/fatepipeline-evn/lib/python3.8/site-packages/pipeline/utils/invoker/job_submitter.py", line 113, in upload_data
    raise ValueError("job submit failed, err msg: {}".format(result))
ValueError: job submit failed, err msg: {'retcode': 100, 'retmsg': 'Connection refused, Please check if the fate flow service is started'}

[cchanzl]

you initiated the pipeline but not flow.

try this step: flow init --ip --port