code: def main(config="../config.yaml", namespace=""):
      if isinstance(config, str):
          config = test_utils.load_job_config(config)
      parties = config.parties
      guest = parties.guest[0]
      host = parties.host[0]
  
      pipeline = FateFlowPipeline().set_parties(guest=guest, host=host)
      if config.task_cores:
          pipeline.conf.set("task_cores", config.task_cores)
      if config.timeout:
          pipeline.conf.set("timeout", config.timeout)
  
      reader_0 = Reader("reader_0")
      reader_0.guest.task_parameters(
          namespace=f"experiment{namespace}", name="breast_hetero_guest"
      )
      reader_0.hosts[[0, 1]].task_parameters(
          namespace=f"experiment{namespace}", name="breast_hetero_host"
      )
      reader_1 = Reader("reader_1")
      reader_1.guest.task_parameters(
          namespace=f"experiment{namespace}", name="breast_hetero_guest"
      )
      reader_1.hosts[[0, 1]].task_parameters(
          namespace=f"experiment{namespace}", name="breast_hetero_host"
      )
      psi_0 = PSI("psi_0", input_data=reader_0.outputs["output_data"])
      psi_1 = PSI("psi_1", input_data=reader_1.outputs["output_data"])
  
      sample_0 = Sample(
          "sample_0",
          runtime_parties=dict(guest=guest),
          frac={0: 0.5},
          replace=False,
          hetero_sync=False,
          input_data=psi_0.outputs["output_data"],
      )
  
      sample_1 = Sample(
          "sample_1",
          runtime_parties=dict(host=host),
          n=1000,
          replace=True,
          hetero_sync=False,
          input_data=psi_0.outputs["output_data"],
      )
  
      pipeline.add_tasks(
          [reader_0, reader_1, psi_0, psi_1, sample_0, sample_1]
      )
  
      # pipeline.add_task(hetero_feature_binning_0)
      pipeline.compile()
      # print(pipeline.get_dag())
      pipeline.fit()
  
imports: import argparse
  from fate_client.pipeline import FateFlowPipeline
  from fate_client.pipeline.components.fate import Sample, PSI, Reader
  from fate_client.pipeline.utils import test_utils
label_desc: Use image node_id 1 for calling a global function with example usage: main(config, namespace) without return types