Commits

Breadcrumbs

History for

onmaster

User selector

All users

All time

Commit History

Commits on Jul 3, 2024

• Fix bad type declarations.

  robertwb

  committed
  d4de077

  Copy full SHA for d4de077

• Fix circular references, mypy complaints.

  robertwb

  committed
  abdb1b7

  Copy full SHA for abdb1b7

Commits on Jul 2, 2024

• Modernize python type hints for apache_beam/runners/direct

  robertwb

  committed
  0763d7e

  Copy full SHA for 0763d7e

Commits on Oct 4, 2021

• [BEAM-11516] Upgrade to pylint 2.11.1, fix warnings (#15612)

  Show description for 8e217ea
  benEng

  authored
  8e217ea

  Copy full SHA for 8e217ea

Commits on Sep 15, 2021

• [BEAM-12794] Remove obsolete uses of sys.exc_info. (#15507)

  Show description for 9a40e41
  

  Kyle Weaver

  authored
  9a40e41

  Copy full SHA for 9a40e41

Commits on Apr 22, 2021

• [BEAM-7372] cleanup py2 codepath from apache_beam/runners/direct, job, portability and test

  Show description for 51541a5
  yoshikiobata

  committed
  51541a5

  Copy full SHA for 51541a5

Commits on Jul 27, 2020

• Gracefully stop the TestStream RPC if the job stops.

  Show description for 3b66d82
  

  Sam Rohde

  committed
  3b66d82

  Copy full SHA for 3b66d82

Commits on Feb 6, 2020

• [BEAM-9175] Yapf everywhere!

  kamilwu

  committed
  9c3941f

  Copy full SHA for 9c3941f

Commits on Jan 8, 2020

• Add # pytype: skip-file before first import statement in each py file (#10533)

  boyuanzz

  authored
  7547ac6

  Copy full SHA for 7547ac6

Commits on Dec 11, 2019

• [BEAM-7746] Add python type hints (part 1) (#9915)

  Show description for df37616
  

  chadrik

  authored and

  pabloem

  committed
  df37616

  Copy full SHA for df37616

Commits on Nov 16, 2019

• [BEAM-8661] Moving runners to have per-module logger (#10097)

  Show description for 49d6efd
  pabloem

  authored
  49d6efd

  Copy full SHA for 49d6efd

Commits on Aug 14, 2018

• Implement integration tests for PubSub on DirectRunner

  Show description for 1918082
  udim

  committed
  1918082

  Copy full SHA for 1918082

Commits on Jul 5, 2018

• removed unnecessary install_aliases, import io and unicode imports

  Fematich

  committed
  0956fdf

  Copy full SHA for 0956fdf

Commits on Jun 21, 2018

• Cleanup futurize runners

  Fematich

  committed
  b908795

  Copy full SHA for b908795

• Futurize direct runner

  Fematich

  committed
  7548587

  Copy full SHA for 7548587

Commits on Apr 18, 2018

• Python Metrics now rely on StateSampler state.

  pab-goog

  committed
  d605391

  Copy full SHA for d605391

Commits on Apr 5, 2018

• [BEAM-4024] Fix AttributeError in BundleBasedDirectRunner

  charlesccychen

  committed
  1b2b747

  Copy full SHA for 1b2b747

Commits on Apr 2, 2018

• [BEAM-3818] Add support for streaming side inputs in the DirectRunner (part 2: unblock tasks as the _SideInputsContainer gets updated) (#4949)

  Show description for fdbd7fa
  

  mariapython

  authored and

  aaltay

  committed
  fdbd7fa

  Copy full SHA for fdbd7fa

Commits on Mar 3, 2018

• Merge pull request #4744: [BEAM-3744] Add support for Pub/Sub messages with attributes

  chamikaramj

  authored
  2fd60a2

  Copy full SHA for 2fd60a2

Commits on Mar 2, 2018

• Add support for Pub/Sub messages with attributes.

  udim

  committed
  91b05c3

  Copy full SHA for 91b05c3

Commits on Feb 23, 2018

• First pass at fixing all of E999 (invalid parsing) errors in Py3 found by flake8

  Show description for 9850d3f
  holdenk

  committed
  9850d3f

  Copy full SHA for 9850d3f

Commits on Feb 7, 2018

• Add test for processing-time timer

  mariapython

  committed
  4f681ee

  Copy full SHA for 4f681ee

Commits on Jan 29, 2018

• [BEAM-3537] Allow more general eager in-process pipeline execution (#4492)

  Show description for d920644
  

  charlesccychen

  authored and

  robertwb

  committed
  d920644

  Copy full SHA for d920644

Commits on Dec 19, 2017

• Adds support for processing Splittable DoFns using DirectRunner.

  Show description for 5443406
  chamikaramj

  committed
  5443406

  Copy full SHA for 5443406

Commits on Dec 14, 2017

• Add review commnets

  mariapython

  committed
  79e167f

  Copy full SHA for 79e167f

• Add Python processing-time timers and clock injection

  mariapython

  committed
  6bcf84f

  Copy full SHA for 6bcf84f

Commits on Nov 13, 2017

• Integrate bundle retry code for the DirectRunner

  

  mariapython

  authored and

  chamikaramj

  committed
  9a183f9

  Copy full SHA for 9a183f9

Commits on Sep 6, 2017

• Incorporate partial writeout fix

  

  mariapython

  authored and

  aaltay

  committed
  095b09b

  Copy full SHA for 095b09b

Commits on Sep 2, 2017

• Improve bundle retry display.

  

  mariapython

  authored and

  aaltay

  committed
  453896a

  Copy full SHA for 453896a

Commits on Aug 25, 2017

• Actually wait for exector service to shutdown

  

  rryk

  authored and

  aaltay

  committed
  2dea491

  Copy full SHA for 2dea491

Commits on Aug 22, 2017

• Allow termination of DirectRunner execution with Ctrl-C

  

  charlesccychen

  authored and

  aaltay

  committed
  a493f32

  Copy full SHA for a493f32

Commits on Aug 13, 2017

• Add initial bundle retry code

  

  mariapython

  authored and

  aaltay

  committed
  1f2dddd

  Copy full SHA for 1f2dddd

Commits on Jun 21, 2017

• Allow production of unprocessed bundles, introduce TestStream evaluator in DirectRunner

  

  charlesccychen

  authored and

  aaltay

  committed
  3520f94

  Copy full SHA for 3520f94

• Use state / timer API for DirectRunner timer firings

  

  charlesccychen

  authored and

  aaltay

  committed
  56041b7

  Copy full SHA for 56041b7

Commits on Jun 16, 2017

• Introduce pending bundles and RootBundleProvider in DirectRunner

  

  charlesccychen

  authored and

  aaltay

  committed
  5aee624

  Copy full SHA for 5aee624