[core][adag] aDAG silently errors if task bind args do not match function signature

[stephanie-wang]

What happened + What you expected to happen

We should throw an error if a task's bind args do not match its function signature.

Versions / Dependencies

3.0dev

Reproduction script

@ray.remote
class Actor:
  def foo(self):
    # doesn't take any args.
    return

a = Actor.remote()
with ray.dag.InputNode() as inp:
  # this line should error.
  dag = a.foo.bind(inp)

Issue Severity

None

[kevin85421]

I can't reproduce this issue. The exception is thrown when execute is called. Or should the exception be thrown when bind is called?

import ray
from ray.dag import InputNode


@ray.remote
class Actor:
  def foo(self):
    # doesn't take any args.
    return

a = Actor.remote()
with InputNode() as inp:
  # this line should error.
  dag = a.foo.bind(inp)
compiled_dag = dag.experimental_compile()

ref = dag.execute(5)
print(ray.get(ref))

[rkooo567]

I think the ideal case is .bind raise an exception (because that's easiest to debug)

a.foo.bind(inp) requires a single input, but the function `Actor.foo` doesn't accept any argument 

[stephanie-wang]

Hmm @woshiyyya can you comment on your use case? I haven't tried to reproduce yet but I thought you ran into this bug earlier.

[rkooo567]

@stephanie-wang i actually already have a pr out to fix it I think

[stephanie-wang]

@stephanie-wang i actually already have a pr out to fix it I think

Can you link to the PR and assign yourself? If not, this is a good first issue.

[rkooo567]

done!