mirror of
https://github.com/fluencelabs/aqua.git
synced 2025-03-16 04:00:50 +00:00
d057a5e695
* Refactor * deprecate `module`, force `aqua`, fix integration and unit tests * fix ImportFromSpec * Savepoint * Fix * Semantic error on module header * Refactor * Add begin token * Fix tests * Remove DHT examples * Use git aqua-lib * Fix headers * Fix headers * Fix headers * Fix headers * Fix headers * Fix headers * Fix headers * Fix test * Unignore tests * Update aqua-lib --------- Co-authored-by: DieMyst <dmitry.shakhtarin@fluence.ai>
41 lines
763 B
Plaintext
41 lines
763 B
Plaintext
aqua M
|
|
|
|
export bugLng317
|
|
|
|
service MyOp("op"):
|
|
identity(s: string) -> string
|
|
|
|
ability WorkerJob:
|
|
runOnSingleWorker(w: string) -> []string
|
|
|
|
func runJob(j: -> []string) -> []string:
|
|
<- j()
|
|
|
|
func disjoint_run{WorkerJob}() -> -> []string:
|
|
run = func () -> []string:
|
|
r <- WorkerJob.runOnSingleWorker("a")
|
|
<- r
|
|
<- run
|
|
|
|
func empty() -> string:
|
|
a = "empty"
|
|
<- a
|
|
|
|
func bugLng317() -> []string:
|
|
|
|
res: *string
|
|
|
|
outer = () -> string:
|
|
<- empty()
|
|
|
|
clos = () -> -> []string:
|
|
job2 = () -> []string:
|
|
res <- outer()
|
|
res <- MyOp.identity("identity")
|
|
<- res
|
|
<- job2
|
|
worker_job = WorkerJob(runOnSingleWorker = clos())
|
|
subnet_job <- disjoint_run{worker_job}()
|
|
finalRes <- runJob(subnet_job)
|
|
<- finalRes
|