Граф коммитов

4704 Коммитов

Автор SHA1 Сообщение Дата
Guillermo Rodriguez Cano 34f827f04c [AIRFLOW-2301] Sync files of an S3 key with a GCS path
Closes #3216 from wileeam/s3-to-gcs-operator
2018-04-13 09:32:22 +02:00
Kengo Seki 5cb530b455 [AIRFLOW-2293] Fix S3FileTransformOperator to work with boto3
S3FileTransformOperator doen't work for now since
it uses a function
which is no longer supported by boto3. This PR
replaces it with a
valid function and adds an unit test for this
operator.

Closes #3200 from sekikn/AIRFLOW-2293
2018-04-12 09:28:18 +02:00
Guillermo Rodriguez Cano 1fa71f5a5c [AIRFLOW-3212][AIRFLOW-2314] Remove only leading slash in GCS path
Closes #3212 from wileeam/fix-gcs-hook-helper-
function
2018-04-12 09:18:36 +02:00
Sergio Díaz Bautista bc6feea031 [AIRFLOW-1509][AIRFLOW-442] SFTP Sensor
Closes #3213 from sdiazb/sftp_sensor
2018-04-12 09:15:10 +02:00
David Volquartz Lebech d9bf1edd44 [AIRFLOW-2291] Add optional params to ML Engine
This commit adds three extra optional parameters
to the
`MLEngineTrainingOperator` as well as a new unit
test for the
`MLEngineVersionOperator`

Closes #3202 from dlebech/ml-engine-python-version
2018-04-11 14:15:06 +02:00
Guillermo Rodríguez Cano 65e7025f3a [AIRFLOW-1774] Allow consistent templating of arguments in MLEngineBatchPredictionOperator
Fix a minor typo and a wrong non-default
assignment

Fix one more typo

Adapt tests to new error messages and fix another
typo

Fix exception type in utils operator test class

Improve cleansing of non-valid training and
prediciton job names

Closes #2746 from wileeam/ml-engine-prediction-
job-normalization
2018-04-11 11:57:21 +02:00
Fokko Driesprong 3475faf6ba [AIRFLOW-2302] Add missing operators and hooks
Many operators and hooks are not listed in the
config, and therefore
not picked up by the docks generator.

Closes #3201 from Fokko/airflow-2302-add-missing-
docs
2018-04-11 11:55:29 +02:00
Tamu 69ccf84321 [AIRFLOW-2312] Docs Typo Correction: Corresponding
# JIRA
[x] My PR addresses the following Airflow JIRA
issues and references them in the PR title.
*
https://issues.apache.org/jira/browse/AIRFLOW-2312

# Description

[x] Here are some details about my PR

Minor typo fix in the docs. `correpsonding` to
`corresponding`

# Tests
[x] My PR adds the following unit tests OR does
not need testing for this extremely good reason:

I assume I don't need testing for docs

# Commits

[x] My commits all reference JIRA issues in their
subject lines, and I have squashed multiple
commits if they address the same issue. In
addition, my commits follow the guidelines from
"How to write a good git commit message":

1. Subject is separated from body by a blank line
2. Subject is limited to 50 characters
3. Subject does not end with a period
4. Subject uses the imperative mood ("add", not
"adding")
5. Body wraps at 72 characters
6. Body explains "what" and "why", not "how"

Closes #3211 from tamsanh/patch-1
2018-04-11 11:42:46 +02:00
Bolke de Bruin 39b7d7d87c [AIRFLOW-1623] Trigger on_kill method in operators
on_kill methods were not triggered, due to
processes
not being properly terminated. This was due to the
fact
the runners use a shell which is then replaced by
the
child pid, which is unknown to Airflow.

Closes #3204 from bolkedebruin/AIRFLOW-1623
2018-04-11 08:05:42 +02:00
Joy Gao e58d0c9e2b Merge pull request #3184 from johnarnold/johnar/env3 2018-04-10 18:14:39 -07:00
John Arnold (AZURE) 354492bc59 [AIRFLOW-2162] When impersonating another user, pass env variables to sudo 2018-04-10 21:47:45 +00:00
Tao feng dfff04671b [AIRFLOW-2304] Update quickstart doc to mention scheduler part
Closes #3207 from feng-tao/airflow-2304
2018-04-10 09:18:20 +02:00
Tao feng e50eea6295 [AIRFLOW-1633] docker_operator needs a way to set shm_size
Closes #3199 from feng-tao/airflow_1633
2018-04-10 09:17:15 +02:00
Kengo Seki d9f22e44c0 [AIRFLOW-1340] Add S3 to Redshift transfer operator
Currently RedshiftToS3Transfer (UNLOAD) exists but
the opposite doesn't.
This PR adds COPY operation as
S3ToRedshiftTransfer.

Closes #3161 from sekikn/AIRFLOW-1340
2018-04-10 09:13:04 +02:00
Guillermo Rodriguez Cano 687bd03df0 [AIRFLOW-2303] Lists the keys inside an S3 bucket
Lists the keys matching a prefix and a delimiter inside an S3 bucket

Closes #3203 from wileeam/s3-list-operator
2018-04-10 09:07:39 +02:00
Unknown e2aeebea38 [AIRFLOW-2209] restore flask_login imports
ignore unused import with flake8

Closes #3124 from berislavlopac/AIRFLOW-2209
2018-04-10 09:04:39 +02:00
Guillermo Rodríguez Cano 3beb9bcb51 [AIRFLOW-2306] Add Bonnier Broadcasting to list of current users
Closes #3206 from wileeam/add-bbr-to-readme
2018-04-09 14:50:25 -07:00
Kengo Seki 44ce9ca71b [AIRFLOW-2305][AIRFLOW-2027] Fix CI failure caused by []
Closes #3205 from sekikn/AIRFLOW-2305
2018-04-09 21:07:17 +02:00
Marcin Szymanski b3dea2f0d4 [AIRFLOW-2281] Add support for Sendgrid categories
Closes #3188 from ms32035/sendgrid_categories
2018-04-09 10:51:25 +02:00
Dan Davydov 3c4f1fd9e6 [AIRFLOW-2027] Only trigger sleep in scheduler after all files have parsed
Closes #2986 from aoen/ddavydov--open_source_disab
le_unecessary_sleep_in_scheduler_loop
2018-04-09 10:22:11 +02:00
milanvdm 3ece6f6dcb [AIRFLOW-2256] SparkOperator: Add Client Standalone mode and retry mechanism
Closes #3163 from milanvdm/milanvdm/improve-spark-
operator
2018-04-09 10:20:44 +02:00
niels 4e80b5f10a [AIRFLOW-2284] GCS to S3 operator
Closes #3190 from NielsZeilemaker/gcp_to_s3
2018-04-09 09:59:35 +02:00
Bolke de Bruin a30f009aeb [AIRFLOW-2287] Update license notices
Closes #3195 from bolkedebruin/AIRFLOW-2287
2018-04-09 00:32:09 -07:00
r39132 f7f1d38bad Closes apache/incubator-airflow#3192 *Already Merged* 2018-04-08 13:03:27 -07:00
r39132 347acbb034 [AIRFLOW-2296] Add Cinimex DataLab to Readme
Closes #3198 from r39132/add_cinemex_to_readme
2018-04-08 12:51:01 -07:00
charlesverdad 9b1bfb588b [AIRFLOW-2298] Add Kalibrr to who uses airflow
Closes #3194 from charlesverdad/patch-3
2018-04-08 20:27:45 +02:00
Kengo Seki a5943a1425 [AIRFLOW-2292] Fix docstring for S3Hook.get_wildcard_key
Fix a misleading description and wrong parameter
names
in S3Hook.get_wildcard_key's docstring.

Closes #3196 from sekikn/AIRFLOW-2292
2018-04-08 20:15:15 +02:00
Bolke de Bruin 57f79ba4c4 [AIRFLOW-XXX] Update PR template 2018-04-06 19:10:05 +02:00
Bolke de Bruin c69e2ef4ac [AIRFLOW-XXX] Remove outdated migrations.sql 2018-04-06 19:04:51 +02:00
Bolke de Bruin e65a04eec6 [AIRFLOW-2287] Add license header to docs/Makefile 2018-04-06 19:02:49 +02:00
Siddharth Anand a15bd80481 *Kick mirroring again* 2018-04-05 22:18:36 -07:00
Siddharth Anand 04262eb9b6 *Kick mirroring* 2018-04-05 19:07:14 -07:00
Siddharth Anand dcfadcdf4d [AIRFLOW-2286] Add tokopedia to the readme 2018-04-05 19:01:09 -07:00
Siddharth Anand 9804f48d46 Closes apache/incubator-airflow#2953 *No movement from submitter* 2018-04-05 18:45:52 -07:00
Joy Gao 86f30debd6 Merge pull request #3178 from TJBIII/discord_webhook_operator 2018-04-05 18:38:50 -07:00
Thomas Buida 651e309010 [AIRFLOW-2273] Add Discord webhook operator/hook
Add Discord webhook operator and hook to allow posting of messages
to a Discord channel via Discord incoming webhooks.
2018-04-05 17:41:32 -05:00
Joy Gao 8c9d3befb1 Merge pull request #3150 from devinXL8/AIRFLOW-2200 2018-04-05 00:27:42 -07:00
Joy Gao 87a1774cf7 Merge pull request #3189 from tedmiston/updating-doc-grammar-fix 2018-04-05 00:00:01 -07:00
Joy Gao f865c78988 Merge pull request #3177 from whynick1/master 2018-04-04 17:50:12 -07:00
Taylor D. Edmiston 9bdcc4760a [AIRFLOW-2282] Fix grammar in UPDATING.md
Also remove trailing whitespace.
2018-04-04 17:28:53 -04:00
devinXL8 c4ba1051a7 [AIRFLOW-2200] Add snowflake operator with tests 2018-04-04 15:10:00 -04:00
David Klosowski 9c0c4264c3 [AIRFLOW-2178] Add handling on SLA miss errors
Closes #3173 from d3cay1/airflow2178-master
2018-04-04 09:19:59 +02:00
Hongyi Wang 4c89e440ef [AIRFLOW-2169] Fix type 'bytes' is not JSON serializable in python3 2018-04-03 18:10:42 -07:00
John Arnold (AZURE) d1f94fe20e [AIRFLOW-2215] Pass environment to subproces.Popen in base_task_runner
Closes #3183 from johnarnold/env2
2018-04-03 07:43:18 +02:00
Jin Hyuk Chang 9dba430b68 [AIRFLOW-2253] Add Airflow CLI instrumentation
Closes #3159 from jinhyukchang/cli-instrumentation
2018-04-02 15:16:25 -07:00
Fokko Driesprong a6487d6198 [AIRFLOW-2274] Fix Dataflow tests
Closes #3181 from Fokko/fd-fix-dataflow-test
2018-04-02 18:58:42 +02:00
Michael Peteuil ad81412fba [AIRFLOW-2269] Add Custom Ink as an Airflow user
Closes #3175 from mpeteuil/mpeteuil/add-custom-ink
2018-03-31 11:25:10 +02:00
Fokko Driesprong 98b5c169c6 [AIRFLOW-2259] Dataflow Hook Index out of range
Because the api doesn't return the job, because it
isn't known yet
or because it cannot be found, it could be that
the log lines arent
available yet. Also use the locations based api
call, which returns
the jobs immediately. This call seems to work for
us-central, but
doesn't return any jobs for other regions.

Closes #3165 from Fokko/AIRFLOW-2259
2018-03-31 11:19:31 +02:00
Tao feng bf86b89439 [AIRFLOW-2233] Update updating.md to include the info of hdfs_sensors renaming
Closes #3145 from feng-tao/airflow-2233
2018-03-31 11:16:46 +02:00
Daniel van der Ende 64206615a7 [AIRFLOW-2217] Add Slack webhook operator
Add the Slack webhook hook/operator pair. This
allows posting
messages to Slack in an easy, light-weight manner.

Closes #3129 from danielvdende/AIRFLOW-2217-add-
slack-webhook-operator
2018-03-28 23:23:44 +02:00