Code

Streaming thread safety#581

Code

Closed

JamesWrigley wants to merge 23 commits intojps/stream2JuliaParallel/Dagger.jl:jps/stream2from streaming-thread-safetyJuliaParallel/Dagger.jl:streaming-thread-safetyCopy head branch name to clipboard

+1,793-95

Commits

Commits on Nov 26, 2024

• Delete Dagger.cleanup()

  Show description for 82be9e4
  

  JamesWrigley

  authored and

  jpsamaroo

  committed
  82be9e4

  Copy full SHA for 82be9e4

• Use procs() when initializing EAGER_CONTEXT

  Show description for 3e82247
  

  JamesWrigley

  authored and

  jpsamaroo

  committed
  3e82247

  Copy full SHA for 3e82247

• Add metadata to EagerThunk

  jpsamaroo

  committed
  6d24fd5

  Copy full SHA for 6d24fd5

• Sch: Allow occupancy key to be Any

  jpsamaroo

  committed
  7d3712e

  Copy full SHA for 7d3712e

• Add a --verbose option to runtests.jl

  jpsamaroo

  committed
  aaef343

  Copy full SHA for aaef343

• task-tls: Refactor into DTaskTLS struct

  jpsamaroo

  committed
  0763d99

  Copy full SHA for 0763d99

• cancellation: Add cancel token support

  jpsamaroo

  committed
  488ae7a

  Copy full SHA for 488ae7a

• task-tls: Tweaks and fixes, task_id helper

  jpsamaroo

  committed
  12e1bda

  Copy full SHA for 12e1bda

• cancellation: Add graceful vs. forced

  jpsamaroo

  committed
  d1c467b

  Copy full SHA for d1c467b

• cancellation: Wrap InterruptException in DTaskFailedException

  jpsamaroo

  committed
  ef2ea1e

  Copy full SHA for ef2ea1e

• Sch: Add unwrap_nested_exception for DTaskFailedException

  jpsamaroo

  committed
  09fa4b7

  Copy full SHA for 09fa4b7

• Add task_id for DTask

  jpsamaroo

  committed
  f593648

  Copy full SHA for f593648

• dagdebug: Always yield to avoid heisenbugs

  jpsamaroo

  committed
  711489b

  Copy full SHA for 711489b

• tests: Add offline mode

  jpsamaroo

  committed
  0620a02

  Copy full SHA for 0620a02

• dagdebug: Add JULIA_DAGGER_DEBUG config variable

  jpsamaroo

  committed
  4daf50e

  Copy full SHA for 4daf50e

• options: Add internal helper to strip all options

  jpsamaroo

  committed
  1d796a2

  Copy full SHA for 1d796a2

• tests: Test DTaskFailedException inner type

  jpsamaroo

  committed
  73a24ad

  Copy full SHA for 73a24ad

• Sch: Skip not-yet-inited workers

  jpsamaroo

  committed
  8d04144

  Copy full SHA for 8d04144

• Add streaming API

  jpsamaroo

  committed
  e772af0

  Copy full SHA for e772af0

Commits on Nov 30, 2024

• Remove duplicate errormonitor()

  Show description for ec44e08
  JamesWrigley

  committed
  ec44e08

  Copy full SHA for ec44e08

Commits on Dec 1, 2024

• Allow nothing to be thrown in dynamic_listener!()

  Show description for e43151f
  JamesWrigley

  committed
  e43151f

  Copy full SHA for e43151f

• Unwrap nested exceptions in the streaming task input handlers

  Show description for 09bfd56
  JamesWrigley

  committed
  09bfd56

  Copy full SHA for 09bfd56

• Wait for input/output handlers to finish when closing a StreamStore

  Show description for 96a0c46
  JamesWrigley

  committed
  96a0c46

  Copy full SHA for 96a0c46