workflows-py

run-llama/workflows-py

Fork 0

mirror of https://github.com/run-llama/workflows-py.git synced 2026-07-16 05:31:56 -04:00

Commit Graph

Select branches

Hide Pull Requests

adrian/child-workflow-prep-refactors

adrian/child-workflows

adrian/child-workflows-docs

adrian/child-workflows-durable

adrian/child-workflows-page

adrian/child-workflows-runtime-compat

adrian/child-workflows-slim

adrian/fan-out-async-iterator

adrian/fan-out-fan-in-l0

adrian/handler-id-quote-issue-53e3

adrian/issue-404

adrian/llamactl-get-split

adrian/llamactl-organizations-use

adrian/mcp

adrian/multi-result

adrian/server-decorator

adrian/store-interface

adrian/test-ctx

adrian/version-bump

adrian/wf-registry

adrian/workflow-pressure-diagnostics

adrianbot/child-workflows-recursive

adrianbot/cw-stack-1-broker-tree

adrianbot/cw-stack-3-alive-timeout

adrianbot/mlflow-dbos-e2e

adrianbot/mlflow-workflow-tracing-tests

adrianbot/statedb-go-binary

changeset-release/dev

changeset-release/main

chore/fix-lint-323

chore/fix-lint-330

chore/fix-lint-525

chore/fix-lint-594

claude/add-dbos-test-suite-v0yfb

claude/add-durable-workflow-example-YnY23

claude/add-runtime-decorator-abstractions-UJNsv

claude/centralize-instance-checks-y7ogi1

claude/fix-database-locked-tests-d2yrv

claude/fix-handler-idle-state-SCxQj

claude/organize-examples-KJFTa

claude/plan-operator-namespace-jzsmq

claude/refactor-workflows-server-package-hqICG

claude/relative-workflow-paths-RGVg8

claude/release-idle-workflows-VaCpR

claude/resolve-package-conflicts-dV32a

claude/setup-python-311-env-3BfmE

claude/simplify-mapreduce-syntax-2CPyP

claude/slack-feedback-notification-PehCn

claude/test-precommit-fix-sACsb

clelia/agentcore-memory

clelia/gather-in-step-decorator

clelia/golden-examples

copilot/sub-pr-202

cursor/LI-3710-prevent-workflow-server-crash-on-invalid-reload-3421

cursor/LI-3715-stop-workflow-handler-and-cancel-tasks-807e

cursor/LI-3716-filter-internal-events-in-workflow-consumer-eb17

cursor/LI-3867-refactor-event-api-for-consistency-and-flexibility-dc87

cursor/LI-3952-generate-workflow-server-reference-docs-0107

cursor/LI-4105-update-wait-for-event-documentation-3bdd

cursor/LI-4463-implement-lazy-file-reference-system-b1b3

cursor/LI-4612-implement-dedicated-stop-event-subtypes-for-failures-86ee

logan/attach_sequence_number_to_events

logan/building_blocks

logan/child_workflows

logan/error-handling

logan/handler_metadata

logan/typed_state_poc

main

massi/api-reference

quickstart

update-debugger-assets

v1.3.1

vasu/retryable_exceptions

#1

#10

#100

#101

#102

#103

#104

#105

#106

#107

#108

#109

#110

#111

#112

#113

#114

#115

#116

#117

#118

#119

#120

#121

#122

#123

#124

#125

#126

#127

#129

#13

#130

#131

#132

#133

#134

#135

#136

#137

#139

#14

#140

#141

#142

#143

#144

#145

#146

#147

#148

#149

#15

#150

#151

#152

#153

#154

#155

#156

#157

#158

#159

#16

#160

#160

#161

#163

#165

#166

#167

#168

#169

#17

#170

#171

#172

#174

#175

#176

#177

#178

#179

#18

#180

#181

#182

#183

#184

#185

#186

#187

#188

#189

#19

#190

#193

#194

#195

#196

#197

#198

#199

#2

#20

#200

#201

#202

#203

#204

#205

#206

#207

#208

#209

#21

#210

#211

#212

#213

#214

#215

#216

#217

#218

#219

#22

#220

#221

#223

#224

#225

#226

#227

#228

#229

#23

#230

#231

#232

#233

#234

#235

#236

#237

#238

#239

#24

#240

#241

#243

#245

#246

#247

#248

#249

#25

#250

#251

#252

#253

#254

#255

#256

#258

#259

#261

#262

#263

#264

#265

#266

#267

#268

#269

#270

#271

#272

#273

#274

#275

#276

#277

#278

#279

#28

#280

#282

#283

#284

#285

#286

#287

#288

#289

#29

#290

#291

#292

#293

#294

#295

#296

#297

#298

#299

#3

#30

#301

#302

#303

#304

#305

#306

#307

#308

#309

#310

#311

#313

#314

#315

#316

#317

#318

#319

#32

#320

#321

#322

#323

#324

#326

#327

#328

#329

#329

#33

#330

#331

#332

#333

#334

#335

#336

#337

#338

#34

#340

#341

#342

#343

#344

#345

#346

#347

#348

#349

#35

#350

#351

#352

#353

#354

#355

#356

#357

#358

#359

#360

#361

#362

#363

#364

#365

#366

#367

#368

#369

#370

#371

#372

#373

#374

#375

#376

#377

#378

#379

#38

#381

#382

#383

#384

#385

#386

#387

#389

#39

#391

#392

#393

#394

#395

#396

#397

#398

#399

#4

#40

#400

#401

#402

#403

#405

#406

#407

#408

#409

#410

#412

#413

#414

#416

#417

#418

#419

#420

#421

#422

#423

#424

#425

#426

#428

#429

#43

#430

#431

#432

#433

#434

#435

#436

#438

#439

#44

#440

#441

#442

#444

#445

#446

#447

#448

#449

#45

#450

#451

#452

#453

#456

#457

#458

#459

#46

#460

#461

#462

#463

#465

#466

#467

#468

#469

#470

#471

#472

#473

#474

#475

#476

#477

#478

#479

#48

#480

#481

#482

#483

#484

#486

#487

#488

#489

#490

#491

#492

#493

#494

#495

#496

#497

#498

#499

#5

#50

#500

#501

#502

#503

#504

#506

#507

#508

#509

#51

#510

#511

#512

#513

#514

#515

#516

#517

#518

#519

#52

#520

#521

#522

#523

#524

#525

#526

#527

#528

#529

#53

#530

#531

#532

#533

#534

#535

#536

#537

#538

#539

#54

#540

#541

#542

#543

#544

#545

#546

#547

#548

#549

#55

#550

#551

#552

#553

#554

#555

#556

#557

#558

#559

#56

#560

#561

#562

#563

#564

#565

#566

#567

#568

#569

#57

#570

#571

#572

#573

#574

#575

#576

#577

#578

#579

#58

#580

#581

#582

#583

#584

#585

#586

#587

#588

#589

#590

#591

#592

#593

#594

#595

#596

#597

#598

#599

#6

#60

#600

#601

#602

#603

#604

#605

#606

#607

#608

#608

#609

#61

#610

#611

#612

#613

#614

#615

#616

#617

#618

#619

#620

#621

#622

#623

#624

#625

#626

#627

#628

#629

#63

#630

#632

#633

#634

#634

#635

#636

#638

#639

#64

#640

#641

#642

#643

#644

#645

#646

#647

#648

#649

#65

#651

#652

#653

#654

#655

#656

#657

#658

#659

#660

#661

#662

#663

#664

#665

#666

#669

#670

#671

#672

#673

#674

#675

#676

#677

#678

#679

#680

#681

#682

#683

#684

#685

#686

#687

#688

#689

#69

#690

#691

#692

#692

#693

#694

#695

#696

#697

#698

#699

#7

#70

#700

#701

#703

#704

#705

#706

#708

#708

#71

#711

#712

#713

#714

#715

#717

#718

#719

#72

#720

#720

#721

#722

#723

#724

#725

#725

#726

#726

#727

#727

#728

#728

#729

#729

#73

#74

#75

#76

#77

#78

#8

#80

#81

#82

#83

#84

#85

#86

#87

#88

#89

#9

#90

#91

#92

#93

#94

#95

#96

#97

#98

#99

llama-agents-agentcore@0.8.10

llama-agents-agentcore@0.8.11

llama-agents-agentcore@0.8.12

llama-agents-agentcore@0.8.13

llama-agents-agentcore@0.8.14

llama-agents-agentcore@0.8.15

llama-agents-agentcore@0.8.16

llama-agents-agentcore@0.8.17

llama-agents-agentcore@0.8.18

llama-agents-agentcore@0.8.19

llama-agents-agentcore@0.8.8

llama-agents-agentcore@0.8.9

llama-agents-agentcore@0.9.0

llama-agents-agentcore@0.9.1

llama-agents-agentcore@0.9.2

llama-agents-agentcore@0.9.3

llama-agents-agentcore@0.9.4

llama-agents-appserver@0.10.3

llama-agents-appserver@0.10.4

llama-agents-appserver@0.10.5

llama-agents-appserver@0.11.0

llama-agents-appserver@0.11.1

llama-agents-appserver@0.11.2

llama-agents-appserver@0.11.3

llama-agents-appserver@0.11.4

llama-agents-appserver@0.11.5

llama-agents-client@0.1.1

llama-agents-client@0.1.2

llama-agents-client@0.1.3

llama-agents-client@0.2.0

llama-agents-client@0.2.0-rc.0

llama-agents-client@0.2.0-rc.1

llama-agents-client@0.2.1

llama-agents-client@0.2.2

llama-agents-client@0.2.3

llama-agents-client@0.3.0

llama-agents-client@0.3.1

llama-agents-client@0.3.10

llama-agents-client@0.3.11

llama-agents-client@0.3.2

llama-agents-client@0.3.3

llama-agents-client@0.3.4

llama-agents-client@0.3.5

llama-agents-client@0.3.6

llama-agents-client@0.3.7

llama-agents-client@0.3.8

llama-agents-client@0.3.9

llama-agents-control-plane@0.10.4

llama-agents-control-plane@0.10.5

llama-agents-control-plane@0.11.0

llama-agents-control-plane@0.11.1

llama-agents-control-plane@0.12.0

llama-agents-control-plane@0.12.1

llama-agents-control-plane@0.12.2

llama-agents-control-plane@0.12.3

llama-agents-core@0.10.0

llama-agents-core@0.10.1

llama-agents-core@0.10.2

llama-agents-core@0.8.5

llama-agents-core@0.9.0

llama-agents-crds@0.7.2

llama-agents-dbos@0.1.0

llama-agents-dbos@0.1.0-rc.0

llama-agents-dbos@0.1.0-rc.1

llama-agents-dbos@0.1.1

llama-agents-dbos@0.1.2

llama-agents-dbos@0.2.0

llama-agents-dbos@0.2.1

llama-agents-dbos@0.2.2

llama-agents-dbos@0.2.3

llama-agents-dbos@0.3.0

llama-agents-dbos@0.3.1

llama-agents-dbos@0.4.0

llama-agents-dbos@0.4.1

llama-agents-operator@0.11.1

llama-agents-server@0.1.1

llama-agents-server@0.1.2

llama-agents-server@0.1.3

llama-agents-server@0.2.0

llama-agents-server@0.2.0-rc.0

llama-agents-server@0.2.0-rc.1

llama-agents-server@0.2.0-rc.2

llama-agents-server@0.2.0-rc.3

llama-agents-server@0.2.1

llama-agents-server@0.2.2

llama-agents-server@0.2.3

llama-agents-server@0.3.0

llama-agents-server@0.3.1

llama-agents-server@0.3.2

llama-agents-server@0.3.3

llama-agents-server@0.4.0

llama-agents-server@0.4.1

llama-agents-server@0.4.2

llama-agents-server@0.4.3

llama-agents-server@0.4.4

llama-agents-server@0.4.5

llama-agents-server@0.4.6

llama-agents-server@0.4.7

llama-agents-server@0.5.0

llama-agents-server@0.6.0

llama-agents-server@0.6.1

llama-agents-server@0.6.2

llama-agents-server@0.6.3

llama-agents-server@0.6.4

llama-agents-server@v0.1.1

llama-agents-server@v0.1.2

llama-agents-server@v0.1.3

llama-agents-server@v0.2.0

llama-agents-server@v0.2.0-rc.0

llama-agents-server@v0.2.1

llama-agents-server@v0.2.2

llama-agents-server@v0.2.3

llama-agents-server@v0.3.0

llama-agents-server@v0.3.1

llama-agents-server@v0.3.2

llama-agents-server@v0.4.1

llama-agents-server@v0.4.2

llama-agents-server@v0.4.3

llama-agents-server@v0.4.4

llama-agents-server@v0.4.5

llama-agents-server@v0.4.6

llama-agents-server@v0.4.7

llama-agents-server@v0.5.0

llama-agents-server@v0.6.0

llama-agents-server@v0.6.1

llama-agents-server@v0.6.2

llama-agents-server@v0.6.3

llama-agents-server@v0.6.4

llama-agents@0.10.10

llama-agents@0.10.11

llama-agents@0.10.12

llama-agents@0.10.8

llama-agents@0.10.9

llama-agents@0.11.0

llama-agents@0.11.1

llama-agents@0.12.0

llama-agents@0.12.1

llama-agents@0.12.2

llama-agents@0.12.3

llama-agents@0.12.4

llama-agents@0.12.5

llama-index-utils-workflow@0.10.0

llama-index-utils-workflow@0.10.1

llama-index-utils-workflow@0.11.0

llama-index-utils-workflow@0.5.0

llama-index-utils-workflow@0.5.1

llama-index-utils-workflow@0.5.2

llama-index-utils-workflow@0.6.0

llama-index-utils-workflow@0.7.0

llama-index-utils-workflow@0.7.1

llama-index-utils-workflow@0.8.0

llama-index-utils-workflow@0.9.0

llama-index-utils-workflow@0.9.1

llama-index-utils-workflow@0.9.2

llama-index-utils-workflow@0.9.2-rc.0

llama-index-utils-workflow@0.9.3

llama-index-utils-workflow@0.9.3-rc.1

llama-index-utils-workflow@0.9.4

llama-index-utils-workflow@0.9.5

llama-index-utils-workflow@v0.5.0

llama-index-workflows@2.11.2

llama-index-workflows@2.11.3

llama-index-workflows@2.11.4

llama-index-workflows@2.11.5

llama-index-workflows@2.11.6

llama-index-workflows@2.11.7

llama-index-workflows@2.12.0

llama-index-workflows@2.12.1

llama-index-workflows@2.12.2

llama-index-workflows@2.13.0

llama-index-workflows@2.13.1

llama-index-workflows@2.14.0

llama-index-workflows@2.14.1

llama-index-workflows@2.14.2

llama-index-workflows@2.15.0

llama-index-workflows@2.15.0-rc.0

llama-index-workflows@2.15.0-rc.1

llama-index-workflows@2.15.1

llama-index-workflows@2.16.0

llama-index-workflows@2.16.1

llama-index-workflows@2.17.0

llama-index-workflows@2.17.1

llama-index-workflows@2.17.2

llama-index-workflows@2.17.3

llama-index-workflows@2.18.0

llama-index-workflows@2.19.0

llama-index-workflows@2.19.1

llama-index-workflows@2.20.0

llama-index-workflows@2.21.0

llama-index-workflows@2.22.0

llama-index-workflows@2.22.1

llama-index-workflows@2.22.2

llama-index-workflows@v2.11.1

llama-index-workflows@v2.11.2

llama-index-workflows@v2.11.3

llama-index-workflows@v2.11.4

llama-index-workflows@v2.11.5

llama-index-workflows@v2.11.6

llama-index-workflows@v2.11.7

llama-index-workflows@v2.12.0

llama-index-workflows@v2.12.1

llama-index-workflows@v2.12.2

llama-index-workflows@v2.13.0

llama-index-workflows@v2.13.1

llamactl@0.10.0

llamactl@0.10.1

llamactl@0.10.2

llamactl@0.10.3

llamactl@0.6.7

llamactl@0.6.8

llamactl@0.6.9

llamactl@0.7.0

llamactl@0.7.1

llamactl@0.7.2

llamactl@0.7.3

llamactl@0.8.0

llamactl@0.9.0

llamactl@0.9.1

v0.1.0

v0.2.0

v0.2.1

v0.2.2

v1.0.0

v1.0.1

v1.1.0

v1.2.0

v1.3.0

v2.0.0

v2.0.1

v2.1.0

v2.10.0

v2.10.1

v2.10.2

v2.10.3

v2.11.0

v2.11.1

v2.2.0

v2.2.1

v2.2.2

v2.3.0

v2.4.0

v2.5.0

v2.6.0

v2.7.0

v2.7.1

v2.8.0

v2.8.1

v2.8.2

v2.8.3

v2.9.0

v2.9.1

beea90d7b2 Pin fan-out/fan-in recovery, send, and detection semantics Adrian Lyjak 2026-06-11 16:08:42 -04:00
e0eb8b698a Name work-item dispositions instead of inferring them Adrian Lyjak 2026-06-11 15:59:05 -04:00
2509ce8e2d Drop reserved Collect knobs and reuse the tick event codec Adrian Lyjak 2026-06-11 15:55:00 -04:00
6df3997682 Delete dead persisted collection-stream fields Adrian Lyjak 2026-06-11 15:53:10 -04:00
db1258b243 support subclass-aware event routing (#656) vanraj Solanki 2026-06-12 00:13:30 +05:30
69ea5bc1b4 Exclude StopEvent from subclass graph expansion claude/centralize-instance-checks-y7ogi1 Adrian Lyjak 2026-06-11 12:11:30 -04:00
06b6976e99 Add end-to-end subclass routing tests through the server Claude 2026-06-11 12:48:45 +00:00
81c99a5ee4 Centralize event-type matching into a single module Claude 2026-06-11 03:07:13 +00:00
83389a4832 Fire stream-close releases inline and guard serialized-format skew Adrian Lyjak 2026-06-10 11:57:30 -04:00
a7757b1840 Make streams runtime facts and consolidate the level traversal Adrian Lyjak 2026-06-10 11:48:59 -04:00
71c472aaad Consume each stream work item exactly once across merge-shaped steps Adrian Lyjak 2026-06-10 11:36:22 -04:00
7b72132e8f fix(workflows): guard representation subclass checks on py310 vanrajsinh650 2026-06-10 20:26:36 +05:30
7e99220130 test(workflows): cover subclass-aware workflow representation vanrajsinh650 2026-06-10 20:26:05 +05:30
1c7188c99f feat(workflows): support subclass-aware workflow representation vanrajsinh650 2026-06-10 20:20:38 +05:30
93afb5be21 Remodel collection-stream re-delivery around whole work records Adrian Lyjak 2026-06-10 00:46:51 -04:00
7919e2c86f chore(deps): bump idna from 3.11 to 3.15 (#642) dependabot[bot] 2026-06-05 13:35:59 -04:00
ca39cad2fd chore(deps): bump pymdown-extensions from 10.21.2 to 10.21.3 (#641) dependabot[bot] 2026-06-05 13:35:47 -04:00
bae9e78ae2 chore(deps): bump urllib3 from 2.6.3 to 2.7.0 (#636) dependabot[bot] 2026-06-05 13:35:35 -04:00
d710fe4baa chore(deps): bump dulwich from 1.1.0 to 1.2.5 (#645) dependabot[bot] 2026-06-05 13:35:19 -04:00
849df56fa6 chore(deps): bump aiohttp from 3.13.4 to 3.14.0 (#660) dependabot[bot] 2026-06-05 13:34:59 -04:00
5fd64dc91b Update debugger assets (#662) llama-org-ci-bot[bot] 2026-06-05 13:34:46 -04:00
10c7114d28 refactor subclassing tests to define shared test workflows vanrajsinh650 2026-06-04 19:26:01 +05:30
f2455d9360 add changeset for subclass event routing vanrajsinh650 2026-06-04 19:16:42 +05:30
98dc3bd0c3 cover opt-in subclass event routing vanrajsinh650 2026-06-04 07:22:29 +05:30
436a388c41 route event subclasses when opted in vanrajsinh650 2026-06-04 07:16:36 +05:30
2c489f347c add opt-in event subclass config vanrajsinh650 2026-06-04 07:14:57 +05:30
6db7d63fed Update same-type multi-slot join regression Adrian Lyjak 2026-06-01 18:00:46 -04:00
a4e6efb338 Reduce broker state comment churn Adrian Lyjak 2026-06-01 16:11:50 -04:00
e10c111712 Document collection stream state Adrian Lyjak 2026-06-01 16:06:15 -04:00
9b613a4b90 Restore broker state comments Adrian Lyjak 2026-06-01 15:59:08 -04:00
5d65dbc5ad Allow same-type multi-slot joins Adrian Lyjak 2026-06-01 14:43:36 -04:00
aa70f98cd2 Cut collection stream residue Adrian Lyjak 2026-06-01 10:57:37 -04:00
42c978a384 Rebuild fan-in on collection streams Adrian Lyjak 2026-06-01 10:49:39 -04:00
eb56d1dfde Clarify fan-out fan-in comments Adrian Lyjak 2026-05-31 21:03:33 -04:00
a619268317 Trim fan-out fan-in batch semantics Adrian Lyjak 2026-05-31 19:51:46 -04:00
339a89d8fa Add coverage tests for fan-out/fan-in reducer paths Adrian Lyjak 2026-05-31 16:53:48 -04:00
629aba113c Slim fan-out/fan-in changeset and drop bug-process residue from restore comments Adrian Lyjak 2026-05-31 15:34:46 -04:00
eeb86deacd Simplify fan-out/fan-in reducer and drop the inert batch_counted field Adrian Lyjak 2026-05-31 12:17:40 -04:00
bb5cfbb19b Migrate persisted context v1->v2 for batch lineage Adrian Lyjak 2026-05-31 11:29:08 -04:00
dba5364266 Strip L-phase tags and history narration from fan-out/fan-in comments Adrian Lyjak 2026-05-31 11:29:02 -04:00
0c807364d5 chore: fix Lint for #646 (#655) llama-org-ci-bot[bot] 2026-05-31 10:10:07 -04:00
c85128cae0 Count batched send_event members eagerly so they aren't dropped Adrian Lyjak 2026-05-30 20:20:40 -04:00
f283a1af9f Drop deferred L3/slot xfail placeholders (belong to the slot-unification branch) Adrian Lyjak 2026-05-30 20:06:52 -04:00
287fa2c70f Pin send_event-into-batch-join defect and add Take/resume coverage Adrian Lyjak 2026-05-30 19:41:45 -04:00
1c2d000bc4 Replace batch closure counter with explicit live-set membership Adrian Lyjak 2026-05-30 19:20:40 -04:00
38d3facc2b Add behavioral regression tests for fan-out/fan-in batch accounting Adrian Lyjak 2026-05-30 16:52:48 -04:00
b66c0c128d Defer async-iterator fan-out to a follow-up Adrian Lyjak 2026-05-30 13:03:14 -04:00
3a5b5a4b8f Consolidate fan-out/fan-in changesets into one Adrian Lyjak 2026-05-30 12:23:26 -04:00
1a98bfbe16 Pull replayed_events(): unwired stub that misleads on replay Adrian Lyjak 2026-05-30 12:08:38 -04:00
97eea87aa7 Pull AtLeast cardinality to v2 Adrian Lyjak 2026-05-30 11:07:17 -04:00
927494f6d3 Add Collect selection algebra for batch fan-in (L3) Adrian Lyjak 2026-05-30 09:48:14 -04:00
597b23ed56 Fix nested fan-out join, make abort handler honest, fix lint Adrian Lyjak 2026-05-29 10:38:30 -04:00
7428acfc83 xfail two-level nested fan-out pending-count case as a known L2 limitation Adrian Lyjak 2026-05-29 03:09:29 -04:00
a329f70962 Net-neutral enclosing-batch accounting for nested fan-out; replay test records real ticks Adrian Lyjak 2026-05-29 03:04:33 -04:00
01052dd0f4 Fix multi-level closure, record replay ticks from real run, reject list[union] collect Adrian Lyjak 2026-05-29 03:01:29 -04:00
c1c68575e3 Fix multi-level batch closure and downstream fire-on-partial consumer detection Adrian Lyjak 2026-05-29 02:56:55 -04:00
f0a97ded93 Keep enclosing batch pending across nested fan-out and set run id in replay test Adrian Lyjak 2026-05-29 02:52:47 -04:00
1960aa8a15 Scope empty-batch collect firing to the nearest enclosing batch level Adrian Lyjak 2026-05-29 02:48:41 -04:00
f9960e3435 Fire batch-collect steps by downstream reachability so empty batches close Adrian Lyjak 2026-05-29 02:44:18 -04:00
9c24d8b97c Add batch-lineage tests with stream-draining run helper and accept list[E] param Adrian Lyjak 2026-05-29 02:33:48 -04:00
fb7852babd Add changeset for batch-lineage fan-out/fan-in Adrian Lyjak 2026-05-29 02:05:43 -04:00
ccbf87b209 Use pure-reducer replay test and function-scoped loops; accept list[E] param Adrian Lyjak 2026-05-29 02:05:09 -04:00
e4028102ff Add batch-lineage fan-out producers, list[E] collect, closure, and abort Adrian Lyjak 2026-05-29 01:44:20 -04:00
10a3fd1def Thread batch lineage through tick, state, and command layers Adrian Lyjak 2026-05-29 01:36:56 -04:00
3d9b3aed07 Support heterogeneous fan-in via multiple single-event step params Adrian Lyjak 2026-05-29 01:06:55 -04:00
f72d92f1a7 Emit each element of a static list[E] step return as a fan-out Adrian Lyjak 2026-05-29 00:48:25 -04:00
8c7e57bd13 Keep send_event runtime-compatible Adrian Lyjak 2026-05-28 22:42:22 -04:00
5b5909ad04 Make fan-out emissions honest in the type graph Adrian Lyjak 2026-05-28 20:44:55 -04:00
4b87d04836 Fix Coveralls package coverage paths (#657) Adrian Lyjak 2026-06-01 13:21:47 -04:00
1483fe958c support subclass-aware event routing vanrajsinh650 2026-06-01 11:46:05 +05:30
3919e841c1 WIP: restore async-iterator fan-out to redesign as real-time streaming adrian/fan-out-async-iterator Adrian Lyjak 2026-05-30 13:05:24 -04:00
43f875e740 Defer async-iterator fan-out to a follow-up Adrian Lyjak 2026-05-30 13:03:14 -04:00
74e1611981 Consolidate fan-out/fan-in changesets into one Adrian Lyjak 2026-05-30 12:23:26 -04:00
5d0a000172 Pull replayed_events(): unwired stub that misleads on replay Adrian Lyjak 2026-05-30 12:08:38 -04:00
2df5f9c8d5 Pull AtLeast cardinality to v2 Adrian Lyjak 2026-05-30 11:07:17 -04:00
06d4bf93c3 Add Collect selection algebra for batch fan-in (L3) Adrian Lyjak 2026-05-30 09:48:14 -04:00
15585ffe32 Fix nested fan-out join, make abort handler honest, fix lint Adrian Lyjak 2026-05-29 10:38:30 -04:00
f3fae83927 xfail two-level nested fan-out pending-count case as a known L2 limitation Adrian Lyjak 2026-05-29 03:09:29 -04:00
3aed6d03a7 Net-neutral enclosing-batch accounting for nested fan-out; replay test records real ticks Adrian Lyjak 2026-05-29 03:04:33 -04:00
6a89371f39 Fix multi-level closure, record replay ticks from real run, reject list[union] collect Adrian Lyjak 2026-05-29 03:01:29 -04:00
cf8741e89a Fix multi-level batch closure and downstream fire-on-partial consumer detection Adrian Lyjak 2026-05-29 02:56:55 -04:00
1974d7f180 Keep enclosing batch pending across nested fan-out and set run id in replay test Adrian Lyjak 2026-05-29 02:52:47 -04:00
ecbbc1e012 Scope empty-batch collect firing to the nearest enclosing batch level Adrian Lyjak 2026-05-29 02:48:41 -04:00
f02cfeea9d Fire batch-collect steps by downstream reachability so empty batches close Adrian Lyjak 2026-05-29 02:44:18 -04:00
621e9e6bbc Add batch-lineage tests with stream-draining run helper and accept list[E] param Adrian Lyjak 2026-05-29 02:33:48 -04:00
c2b8eafeab Add changeset for batch-lineage fan-out/fan-in Adrian Lyjak 2026-05-29 02:05:43 -04:00
282efacb3e Use pure-reducer replay test and function-scoped loops; accept list[E] param Adrian Lyjak 2026-05-29 02:05:09 -04:00
fa185fb500 Add batch-lineage fan-out producers, list[E] collect, closure, and abort Adrian Lyjak 2026-05-29 01:44:20 -04:00
b6f2ba56fe Thread batch lineage through tick, state, and command layers Adrian Lyjak 2026-05-29 01:36:56 -04:00
769071f6d6 Support heterogeneous fan-in via multiple single-event step params Adrian Lyjak 2026-05-29 01:06:55 -04:00
d82911a761 Emit each element of a static list[E] step return as a fan-out Adrian Lyjak 2026-05-29 00:48:25 -04:00
3a2a11ff73 Keep send_event runtime-compatible Adrian Lyjak 2026-05-28 22:42:22 -04:00
8ff2ab9cf3 Make fan-out emissions honest in the type graph Adrian Lyjak 2026-05-28 20:44:55 -04:00
9a4dd16183 feat(workflows): add opt-in type allowlist for JsonSerializer deserialization (#640) HaoJun 2026-05-22 21:57:05 +08:00
7ff5325302 chore: version packages (#635) llamactl@0.10.2 llama-org-ci-bot[bot] 2026-05-14 19:08:08 -04:00
abc176e6ce Safeguard push-mode auto-push (#639) Adrian Lyjak 2026-05-14 17:57:50 -04:00
06ff626efe fix: projects use/get cross-org lookup (#638) Adrian Lyjak 2026-05-14 16:17:08 -04:00
c9fa9b26e7 Remove migrations from statedb binary adrianbot/statedb-go-binary Adrian Lyjak 2026-05-11 12:05:38 -04:00
3263e9b0f1 chore: version packages (#633) llamactl@0.10.1 llama-org-ci-bot[bot] 2026-05-11 11:07:24 -04:00
db64f0bbbb chore(deps): bump python-multipart from 0.0.26 to 0.0.27 (#628) dependabot[bot] 2026-05-11 11:07:05 -04:00

1 2 3 4 5 ...