Julia function timeout using async and remotecall_fetch fails to find function

Question

I'm trying to kill execution of a function when it times out. Tried to leverage the post here: Julia: Can you set a time limit on eval

It errored on RemoteRef is undefined (I'm using v0.6.0). Replaced RemoteRef with Channel(1). Now the error is

MethodError: no method matching remotecall_fetch (::Int64, ::#test, ::String, ::String, ::String)

addprocs(1) 
@everywhere include("test.jl")  
response = Channel(1)
@async put!(response, remotecall_fetch(2, test, arg1, arg2, arg3))

start=time()
while !isready(response) && (time() - start) < timeoutDuration    
  sleep(0.1)
end

elapsedtime = time()-start

ERROR (unhandled task failure): MethodError: no method matching remotecall_fetch(::Int64, ::#test, ::String, ::String, ::String)

Also tried

@async put!(response, remotecall_fetch(2, ()->test(arg1, arg2, arg3)))

ERROR (unhandled task failure): MethodError: no method matching remotecall_fetch(::Int64, ::##10#12)

Is the second worker unable to find test()?

HarmonicaMuse · Accepted Answer · 2018-01-31 02:04:50Z

0

According to the documentation:

help?> remotecall_fetch
search: remotecall_fetch remotecall_wait

  remotecall_fetch(f, id::Integer, args...; kwargs...)

  Perform fetch(remotecall(...)) in one message. Keyword arguments,
  if any, are passed through to f. Any remote exceptions are captured 
  in a RemoteException and thrown.

  See also fetch and remotecall.

  remotecall_fetch(f, pool::AbstractWorkerPool, args...; kwargs...) -> result

  WorkerPool variant of remotecall_fetch(f, pid, ....). Waits for and 
  takes a free worker from pool and performs a remotecall_fetch on it.

You'd need to do it like this:

@async put!(response, remotecall_fetch(test, 2, arg1, arg2, arg3))

answered Jan 31, 2018 at 2:04

HarmonicaMuse

7,94343 silver badges55 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

Tims Over a year ago

Can I use a @time remotecall_fetch to estimate the actual duration of "test" run?

Tims · Accepted Answer · 2018-01-30 20:33:23Z

0

Syntax issue, worker# should be at the end

@async put!(response, remotecall_fetch(()->test(a1,a2,a3),2) )

answered Jan 30, 2018 at 20:33

Tims

6519 silver badges22 bronze badges

Collectives™ on Stack Overflow

Julia function timeout using async and remotecall_fetch fails to find function

2 Answers 2

1 Comment

Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

2 Answers 2

1 Comment

Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related