Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[AIRFLOW-6786] Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor #7407

Closed
wants to merge 162 commits into from
Closed

[AIRFLOW-6786] Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor #7407

wants to merge 162 commits into from

Commits on Aug 25, 2020

  1. Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor 

    Co-authored-by: Dan Ferguson [email protected]
Co-authored-by: Hanan Shteingart
Co-authored-by: YuanfΞi Zhu
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    55bcd8c View commit details
    Browse the repository at this point in the history

  2. Modifying files in accordance with peer review

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    3706a59 View commit details
    Browse the repository at this point in the history

  3. Moved files to providers package. Externalized connection logic from … 

    …init function
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    3ed7b77 View commit details
    Browse the repository at this point in the history

  4. Fixing Travis CI Linting errors

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    7c50651 View commit details
    Browse the repository at this point in the history

  5. Fixing Travis CI Linting errors

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    89f5764 View commit details
    Browse the repository at this point in the history

  6. Fixed isort issue

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    0874dc2 View commit details
    Browse the repository at this point in the history

  7. produer --> producer

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    531a56b View commit details
    Browse the repository at this point in the history

  8. Added pylint mandated doc strings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    0921de0 View commit details
    Browse the repository at this point in the history

  9. Fixing more pylint issues

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    37d5d1f View commit details
    Browse the repository at this point in the history

  10. Removed unused imports

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    26227a7 View commit details
    Browse the repository at this point in the history

  11. Added comma in documentation

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    d2a4b22 View commit details
    Browse the repository at this point in the history

  12. Modified the templates index file to see the new hooks and sensors

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    ecb8a31 View commit details
    Browse the repository at this point in the history

  13. Tried to fix docstrings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    f3b1086 View commit details
    Browse the repository at this point in the history

  14. Tried to fix docstrings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    0e5a0ae View commit details
    Browse the repository at this point in the history

  15. Apply suggestions from code review

    @kaxil
    kaxil authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    9d379f0 View commit details
    Browse the repository at this point in the history

  16. Update airflow/providers/apache/kafka/sensors/kafka_sensor.py 

    Co-authored-by: Kaxil Naik <[email protected]>
    @dferguson992 @kaxil
    2 people authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    206f9d9 View commit details
    Browse the repository at this point in the history

  17. Update airflow/providers/apache/kafka/sensors/kafka_sensor.py 

    Co-authored-by: Kaxil Naik <[email protected]>
    @dferguson992 @kaxil
    2 people authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    5885b14 View commit details
    Browse the repository at this point in the history

  18. Removed unused imports

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    192a93d View commit details
    Browse the repository at this point in the history

  19. Removed unused imports

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    c221956 View commit details
    Browse the repository at this point in the history

  20. Added new line to readme to trigger builds

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    7fe057e View commit details
    Browse the repository at this point in the history

  21. added the python 3.8 requirements

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    788892d View commit details
    Browse the repository at this point in the history

  22. Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor 

    Co-authored-by: Dan Ferguson [email protected]
Co-authored-by: Hanan Shteingart
Co-authored-by: YuanfΞi Zhu
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    e792bbb View commit details
    Browse the repository at this point in the history

  23. Modifying files in accordance with peer review

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    8cf49a1 View commit details
    Browse the repository at this point in the history

  24. Moved files to providers package. Externalized connection logic from … 

    …init function
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    3334ba8 View commit details
    Browse the repository at this point in the history

  25. Fixing Travis CI Linting errors

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    e6ff806 View commit details
    Browse the repository at this point in the history

  26. Fixing Travis CI Linting errors

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    23b9ed1 View commit details
    Browse the repository at this point in the history

  27. Fixed isort issue

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    136dc9b View commit details
    Browse the repository at this point in the history

  28. produer --> producer

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    8197a59 View commit details
    Browse the repository at this point in the history

  29. Added pylint mandated doc strings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    788586e View commit details
    Browse the repository at this point in the history

  30. Fixing more pylint issues

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    10531c0 View commit details
    Browse the repository at this point in the history

  31. Tried to fix docstrings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    ba86611 View commit details
    Browse the repository at this point in the history

  32. Tried to fix docstrings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    ad2c460 View commit details
    Browse the repository at this point in the history

  33. Apply suggestions from code review

    @kaxil
    kaxil authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    0ec3ec7 View commit details
    Browse the repository at this point in the history

  34. Update airflow/providers/apache/kafka/sensors/kafka_sensor.py 

    Co-authored-by: Kaxil Naik <[email protected]>
    @dferguson992 @kaxil
    2 people authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    da9daf1 View commit details
    Browse the repository at this point in the history

  35. Update airflow/providers/apache/kafka/sensors/kafka_sensor.py 

    Co-authored-by: Kaxil Naik <[email protected]>
    @dferguson992 @kaxil
    2 people authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    8688e6a View commit details
    Browse the repository at this point in the history

  36. Removed unused imports

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    b600971 View commit details
    Browse the repository at this point in the history

  37. Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor 

    Co-authored-by: Dan Ferguson [email protected]
Co-authored-by: Hanan Shteingart
Co-authored-by: YuanfΞi Zhu
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    2789458 View commit details
    Browse the repository at this point in the history

  38. Modifying files in accordance with peer review

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    d5673a2 View commit details
    Browse the repository at this point in the history

  39. Moved files to providers package. Externalized connection logic from … 

    …init function
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    30982c7 View commit details
    Browse the repository at this point in the history

  40. Fixing Travis CI Linting errors

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    2847ce0 View commit details
    Browse the repository at this point in the history

  41. Fixing Travis CI Linting errors

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    4327d3d View commit details
    Browse the repository at this point in the history

  42. Fixed isort issue

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    b858e8b View commit details
    Browse the repository at this point in the history

  43. produer --> producer

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    deba782 View commit details
    Browse the repository at this point in the history

  44. Added pylint mandated doc strings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    5c5c393 View commit details
    Browse the repository at this point in the history

  45. Fixing more pylint issues

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    8a70321 View commit details
    Browse the repository at this point in the history

  46. Removed unused imports

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    f71fa38 View commit details
    Browse the repository at this point in the history

  47. Tried to fix docstrings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    b16b402 View commit details
    Browse the repository at this point in the history

  48. Tried to fix docstrings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    b472e93 View commit details
    Browse the repository at this point in the history

  49. Apply suggestions from code review

    @kaxil
    kaxil authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    b8239d7 View commit details
    Browse the repository at this point in the history

  50. Update airflow/providers/apache/kafka/sensors/kafka_sensor.py 

    Co-authored-by: Kaxil Naik <[email protected]>
    @dferguson992 @kaxil
    2 people authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    57d08d7 View commit details
    Browse the repository at this point in the history

  51. Update airflow/providers/apache/kafka/sensors/kafka_sensor.py 

    Co-authored-by: Kaxil Naik <[email protected]>
    @dferguson992 @kaxil
    2 people authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    4ccf498 View commit details
    Browse the repository at this point in the history

  52. Removed unused imports

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    e02d4cc View commit details
    Browse the repository at this point in the history

  53. adding more weird local files

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    b79063f View commit details
    Browse the repository at this point in the history

  54. Modifying readme to trigger builds

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    1e3ced9 View commit details
    Browse the repository at this point in the history

  55. Revert "Resolved conflicts in requirements files" 

    This reverts commit 9b213d2.
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    4bb1da6 View commit details
    Browse the repository at this point in the history

  56. Updated readme to trigger build

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    169779f View commit details
    Browse the repository at this point in the history

  57. updating requirements files

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    374343f View commit details
    Browse the repository at this point in the history

  58. updated requirements

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    a87b26e View commit details
    Browse the repository at this point in the history

  59. Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor 

    Co-authored-by: Dan Ferguson [email protected]
Co-authored-by: Hanan Shteingart
Co-authored-by: YuanfΞi Zhu
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    5348178 View commit details
    Browse the repository at this point in the history

  60. Modifying files in accordance with peer review

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    2808b6a View commit details
    Browse the repository at this point in the history

  61. Moved files to providers package. Externalized connection logic from … 

    …init function
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    df9aa30 View commit details
    Browse the repository at this point in the history

  62. produer --> producer

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    163b9cf View commit details
    Browse the repository at this point in the history

  63. Added pylint mandated doc strings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    4a11c4a View commit details
    Browse the repository at this point in the history

  64. Fixing more pylint issues

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    2c16224 View commit details
    Browse the repository at this point in the history

  65. Tried to fix docstrings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    9c0ca5d View commit details
    Browse the repository at this point in the history

  66. Tried to fix docstrings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    f06049f View commit details
    Browse the repository at this point in the history

  67. Apply suggestions from code review

    @kaxil
    kaxil authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    646bcf0 View commit details
    Browse the repository at this point in the history

  68. Update airflow/providers/apache/kafka/sensors/kafka_sensor.py 

    Co-authored-by: Kaxil Naik <[email protected]>
    @dferguson992 @kaxil
    2 people authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    0193e67 View commit details
    Browse the repository at this point in the history

  69. Update airflow/providers/apache/kafka/sensors/kafka_sensor.py 

    Co-authored-by: Kaxil Naik <[email protected]>
    @dferguson992 @kaxil
    2 people authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    c092186 View commit details
    Browse the repository at this point in the history

  70. Removed unused imports

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    62b4e5a View commit details
    Browse the repository at this point in the history

  71. updating requirements again

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    c8f2995 View commit details
    Browse the repository at this point in the history

  72. Fixed yaml linting issues

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    857f44e View commit details
    Browse the repository at this point in the history

  73. Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor 

    Co-authored-by: Dan Ferguson [email protected]
Co-authored-by: Hanan Shteingart
Co-authored-by: YuanfΞi Zhu
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    5974f63 View commit details
    Browse the repository at this point in the history

  74. Modifying files in accordance with peer review

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    d4cbb29 View commit details
    Browse the repository at this point in the history

  75. Moved files to providers package. Externalized connection logic from … 

    …init function
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    bae395f View commit details
    Browse the repository at this point in the history

  76. Fixing Travis CI Linting errors

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    7976053 View commit details
    Browse the repository at this point in the history

  77. Fixing Travis CI Linting errors

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    212491d View commit details
    Browse the repository at this point in the history

  78. produer --> producer

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    53b5f97 View commit details
    Browse the repository at this point in the history

  79. Added pylint mandated doc strings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    6813f27 View commit details
    Browse the repository at this point in the history

  80. Fixing more pylint issues

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    15e81a0 View commit details
    Browse the repository at this point in the history

  81. Tried to fix docstrings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    29d333d View commit details
    Browse the repository at this point in the history

  82. Tried to fix docstrings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    93015ef View commit details
    Browse the repository at this point in the history

  83. Apply suggestions from code review

    @kaxil
    kaxil authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    28960e8 View commit details
    Browse the repository at this point in the history

  84. Update airflow/providers/apache/kafka/sensors/kafka_sensor.py 

    Co-authored-by: Kaxil Naik <[email protected]>
    @dferguson992 @kaxil
    2 people authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    605195e View commit details
    Browse the repository at this point in the history

  85. Update airflow/providers/apache/kafka/sensors/kafka_sensor.py 

    Co-authored-by: Kaxil Naik <[email protected]>
    @dferguson992 @kaxil
    2 people authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    a6a2f74 View commit details
    Browse the repository at this point in the history

  86. Removed unused imports

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    556425a View commit details
    Browse the repository at this point in the history

  87. Removed unused imports

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    3f096dc View commit details
    Browse the repository at this point in the history

  88. Updated the requirements files to contain the kafka dependencies

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    48b7f9f View commit details
    Browse the repository at this point in the history

  89. Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor 

    Co-authored-by: Dan Ferguson [email protected]
Co-authored-by: Hanan Shteingart
Co-authored-by: YuanfΞi Zhu
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    de2ad60 View commit details
    Browse the repository at this point in the history

  90. Modifying files in accordance with peer review

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    9d9e41f View commit details
    Browse the repository at this point in the history

  91. Moved files to providers package. Externalized connection logic from … 

    …init function
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    58b7239 View commit details
    Browse the repository at this point in the history

  92. Fixing Travis CI Linting errors

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    fb4e654 View commit details
    Browse the repository at this point in the history

  93. Fixed isort issue

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    677e23f View commit details
    Browse the repository at this point in the history

  94. produer --> producer

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    4972f30 View commit details
    Browse the repository at this point in the history

  95. Added pylint mandated doc strings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    06cae89 View commit details
    Browse the repository at this point in the history

  96. Fixing more pylint issues

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    6c5a96e View commit details
    Browse the repository at this point in the history

  97. Tried to fix docstrings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    d8f1106 View commit details
    Browse the repository at this point in the history

  98. Tried to fix docstrings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    c0275db View commit details
    Browse the repository at this point in the history

  99. Apply suggestions from code review

    @kaxil
    kaxil authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    9de53ae View commit details
    Browse the repository at this point in the history

  100. Update airflow/providers/apache/kafka/sensors/kafka_sensor.py 

    Co-authored-by: Kaxil Naik <[email protected]>
    @dferguson992 @kaxil
    2 people authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    080c3b7 View commit details
    Browse the repository at this point in the history

  101. Update airflow/providers/apache/kafka/sensors/kafka_sensor.py 

    Co-authored-by: Kaxil Naik <[email protected]>
    @dferguson992 @kaxil
    2 people authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    3448223 View commit details
    Browse the repository at this point in the history

  102. Removed unused imports

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    40bfe9e View commit details
    Browse the repository at this point in the history

  103. Modifying readme to trigger builds

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    c4c6e14 View commit details
    Browse the repository at this point in the history

  104. Revert "Resolved conflicts in requirements files" 

    This reverts commit 9b213d2.
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    6d018f4 View commit details
    Browse the repository at this point in the history

  105. Updated readme to trigger build

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    d632949 View commit details
    Browse the repository at this point in the history

  106. updating requirements files

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    7a40db4 View commit details
    Browse the repository at this point in the history

  107. updated requirements

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    e933030 View commit details
    Browse the repository at this point in the history

  108. Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor 

    Co-authored-by: Dan Ferguson [email protected]
Co-authored-by: Hanan Shteingart
Co-authored-by: YuanfΞi Zhu
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    0623f7a View commit details
    Browse the repository at this point in the history

  109. Modifying files in accordance with peer review

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    707b257 View commit details
    Browse the repository at this point in the history

  110. Moved files to providers package. Externalized connection logic from … 

    …init function
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    45229af View commit details
    Browse the repository at this point in the history

  111. produer --> producer

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    7e54375 View commit details
    Browse the repository at this point in the history

  112. Added pylint mandated doc strings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    a01f28c View commit details
    Browse the repository at this point in the history

  113. Fixing more pylint issues

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    4a7fbd2 View commit details
    Browse the repository at this point in the history

  114. Tried to fix docstrings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    4eea9ad View commit details
    Browse the repository at this point in the history

  115. Tried to fix docstrings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    569fa3b View commit details
    Browse the repository at this point in the history

  116. Apply suggestions from code review

    @kaxil
    kaxil authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    0676415 View commit details
    Browse the repository at this point in the history

  117. Update airflow/providers/apache/kafka/sensors/kafka_sensor.py 

    Co-authored-by: Kaxil Naik <[email protected]>
    @dferguson992 @kaxil
    2 people authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    359666c View commit details
    Browse the repository at this point in the history

  118. Update airflow/providers/apache/kafka/sensors/kafka_sensor.py 

    Co-authored-by: Kaxil Naik <[email protected]>
    @dferguson992 @kaxil
    2 people authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    307dce5 View commit details
    Browse the repository at this point in the history

  119. Removed unused imports

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    f036ee6 View commit details
    Browse the repository at this point in the history

  120. Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor 

    Co-authored-by: Dan Ferguson [email protected]
Co-authored-by: Hanan Shteingart
Co-authored-by: YuanfΞi Zhu
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    b82cd1a View commit details
    Browse the repository at this point in the history

  121. Modifying files in accordance with peer review

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    947a3c5 View commit details
    Browse the repository at this point in the history

  122. Moved files to providers package. Externalized connection logic from … 

    …init function
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    4eaf3ee View commit details
    Browse the repository at this point in the history

  123. Fixing Travis CI Linting errors

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    b2928a5 View commit details
    Browse the repository at this point in the history

  124. Fixing Travis CI Linting errors

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    35f0726 View commit details
    Browse the repository at this point in the history

  125. produer --> producer

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    81d086d View commit details
    Browse the repository at this point in the history

  126. Added pylint mandated doc strings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    8f33a4e View commit details
    Browse the repository at this point in the history

  127. Fixing more pylint issues

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    0f5c5c2 View commit details
    Browse the repository at this point in the history

  128. Tried to fix docstrings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    de9e68f View commit details
    Browse the repository at this point in the history

  129. Tried to fix docstrings

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    538880e View commit details
    Browse the repository at this point in the history

  130. Apply suggestions from code review

    @kaxil
    kaxil authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    5c6ae5b View commit details
    Browse the repository at this point in the history

  131. Update airflow/providers/apache/kafka/sensors/kafka_sensor.py 

    Co-authored-by: Kaxil Naik <[email protected]>
    @dferguson992 @kaxil
    2 people authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    baf46c2 View commit details
    Browse the repository at this point in the history

  132. Update airflow/providers/apache/kafka/sensors/kafka_sensor.py 

    Co-authored-by: Kaxil Naik <[email protected]>
    @dferguson992 @kaxil
    2 people authored and dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    fa27127 View commit details
    Browse the repository at this point in the history

  133. Removed unused imports

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    c95686c View commit details
    Browse the repository at this point in the history

  134. Removed unused imports

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    c0463b2 View commit details
    Browse the repository at this point in the history

  135. added the python 3.8 requirements

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    8f9a560 View commit details
    Browse the repository at this point in the history

  136. updating dependencies files

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    edb2a4e View commit details
    Browse the repository at this point in the history

  137. updating requirements again

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    35b548d View commit details
    Browse the repository at this point in the history

  138. Fixed yaml linting issues

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    af69ccc View commit details
    Browse the repository at this point in the history

  139. Modified file perms

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    3d44718 View commit details
    Browse the repository at this point in the history

  140. Modified file perms

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    1085084 View commit details
    Browse the repository at this point in the history

  141. Updated requirements files again

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    a6d55a4 View commit details
    Browse the repository at this point in the history

  142. Fixed indentation issue

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    b755869 View commit details
    Browse the repository at this point in the history

  143. Removed trailing whitespace

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    8262de2 View commit details
    Browse the repository at this point in the history

  144. Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor 

    Co-authored-by: Dan Ferguson [email protected]
Co-authored-by: Hanan Shteingart
Co-authored-by: YuanfΞi Zhu
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    033cd6c View commit details
    Browse the repository at this point in the history

  145. Attempted to rebase?

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    d4af358 View commit details
    Browse the repository at this point in the history

  146. ??

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    5dbd736 View commit details
    Browse the repository at this point in the history

  147. Add KafkaConsumerHook, KafkaProduerHook and KafkaSensor 

    Co-authored-by: Dan Ferguson [email protected]
Co-authored-by: Hanan Shteingart
Co-authored-by: YuanfΞi Zhu
    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    f5ec571 View commit details
    Browse the repository at this point in the history

  148. Modifying files in accordance with peer review

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    cbfd33d View commit details
    Browse the repository at this point in the history

  149. Removed unused imports

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    62f3c57 View commit details
    Browse the repository at this point in the history

  150. Fixed isort issue

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    b69e5ee View commit details
    Browse the repository at this point in the history

  151. adding more weird local files

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    5924491 View commit details
    Browse the repository at this point in the history

  152. Modifying readme to trigger builds

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    7708186 View commit details
    Browse the repository at this point in the history

  153. Updated readme to trigger build

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    6edd921 View commit details
    Browse the repository at this point in the history

  154. Fixed yaml linting issues

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    bf12172 View commit details
    Browse the repository at this point in the history

  155. Modifying readme to trigger builds

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    f2b7f97 View commit details
    Browse the repository at this point in the history

  156. Updated readme to trigger build

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    3a24cc1 View commit details
    Browse the repository at this point in the history

  157. updating dependencies files

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    a03c992 View commit details
    Browse the repository at this point in the history

  158. Modified file perms

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    3e32050 View commit details
    Browse the repository at this point in the history

  159. Removed legacy hook and sensor code

    dan committed Aug 25, 2020
    Configuration menu
    Copy the full SHA
    f9f1fb8 View commit details
    Browse the repository at this point in the history

Commits on Aug 26, 2020

  1. ??????

    dan committed Aug 26, 2020
    Configuration menu
    Copy the full SHA
    f26f880 View commit details
    Browse the repository at this point in the history

Commits on Aug 31, 2020

  1. squash! [AIRFLOW-5500] Fix the trigger_dag api in the case of nested … 

    …subdags
    dan committed Aug 31, 2020
    Configuration menu
    Copy the full SHA
    e245bed View commit details
    Browse the repository at this point in the history

  2. Trying to get this to work

    dan committed Aug 31, 2020
    Configuration menu
    Copy the full SHA
    15835e9 View commit details
    Browse the repository at this point in the history