Make BQWrite accept a write disposition

Bug:615218
Change-Id: Iaf69bcb852ee28bb0f691df71edcab01b74ac06f
Reviewed-on: https://chromium-review.googlesource.com/656083
Commit-Queue: Katie Thomas <katthomas@google.com>
Reviewed-by: Andrii Shyshkalov <tandrii@chromium.org>

Cr-Mirrored-From: https://chromium.googlesource.com/infra/infra
Cr-Mirrored-Commit: c36018d35225ce3c0c6cc00c89e5c01e7d73effc
1 file changed
tree: a7e3da40f05dcfbbfe00e92b52dc130d16902b6f
  1. common/
  2. test/
  3. .coveragerc
  4. __init__.py
  5. cq_attempts.py
  6. README.md
  7. setup.py
README.md

Workflow Testing

To test that your pipeline will run remotely:

python <path-to-dataflow-job> --job_name <pick-a-job-name> \
--project chrome-infra-events --runner DataflowRunner --setup_file \
<infra-checkout-path>/packages/dataflow/setup.py \
--staging_location gs://dataflow-chrome-infra-events/staging --temp_location \
gs://dataflow-chrome-infra-events/temp --save_main_session

Job names should match the regular expression [a-z]([-a-z0-9]{0,38}[a-z0-9]). Navigate to the Dataflow console in your browser (project: chrome-infra-events) and you should see your job running. Wait until it succeeds.