<p dir="auto"><strong>Apache Airflow version</strong>:<br>
2.0.0b3</p>
<p dir="auto"><strong>What happened</strong>:<br>
When Airflow is ran within CeleryExecutor mode and using the new Cloudwatch integration (from <a class="issue-link js-issue-link" data-error-text="Failed to load title" data-id="566055616" data-permission-text="Title is private" data-url="https://github.com/apache/airflow/issues/7437" data-hovercard-type="pull_request" data-hovercard-url="/apache/airflow/pull/7437/hovercard" href="https://github.com/apache/airflow/pull/7437">#7437</a>), log groups and log streams are created, but no log events are pushed to AWS. The Webserver is able to read the log stream as expected. There are no errors, just empty logs within Cloudwatch:<br>
<code class="notranslate">*** Reading remote log from Cloudwatch log_group: airflow-task log_stream: tutorial_taskflow_api_etl_dag/extract/2020-12-02T16_37_07.011589+00_00/1.log.</code></p>
<p dir="auto">By switching to SequentialExecutor (default), with one container acting as both the scheduler and webserver, only then are the logs written as expected:</p>
<div class="snippet-clipboard-content notranslate position-relative overflow-auto" data-snippet-clipboard-copy-content="*** Reading remote log from Cloudwatch log_group: airflow-task log_stream: tutorial_taskflow_api_etl_dag/extract/2020-12-02T18_04_50.259906+00_00/1.log.
Task exited with return code 0
test
Exporting the following env vars:
AIRFLOW_CTX_DAG_OWNER=airflow
AIRFLOW_CTX_DAG_ID=tutorial_taskflow_api_etl_dag
AIRFLOW_CTX_TASK_ID=extract
AIRFLOW_CTX_EXECUTION_DATE=2020-12-02T18:04:50.259906+00:00
AIRFLOW_CTX_DAG_RUN_ID=manual__2020-12-02T18:04:50.259906+00:00
Running &lt;TaskInstance: tutorial_taskflow_api_etl_dag.extract 2020-12-02T18:04:50.259906+00:00 [running]&gt; on host 845928f08686
Started process 152 to run task
Executing &lt;Task(_PythonDecoratedOperator): extract&gt; on 2020-12-02T18:04:50.259906+00:00

--------------------------------------------------------------------------------
Starting attempt 1 of 1

--------------------------------------------------------------------------------
Dependencies all met for &lt;TaskInstance: tutorial_taskflow_api_etl_dag.extract 2020-12-02T18:04:50.259906+00:00 [queued]&gt;
Dependencies all met for &lt;TaskInstance: tutorial_taskflow_api_etl_dag.extract 2020-12-02T18:04:50.259906+00:00 [queued]&gt;
"><pre class="notranslate"><code class="notranslate">*** Reading remote log from Cloudwatch log_group: airflow-task log_stream: tutorial_taskflow_api_etl_dag/extract/2020-12-02T18_04_50.259906+00_00/1.log.
Task exited with return code 0
test
Exporting the following env vars:
AIRFLOW_CTX_DAG_OWNER=airflow
AIRFLOW_CTX_DAG_ID=tutorial_taskflow_api_etl_dag
AIRFLOW_CTX_TASK_ID=extract
AIRFLOW_CTX_EXECUTION_DATE=2020-12-02T18:04:50.259906+00:00
AIRFLOW_CTX_DAG_RUN_ID=manual__2020-12-02T18:04:50.259906+00:00
Running &lt;TaskInstance: tutorial_taskflow_api_etl_dag.extract 2020-12-02T18:04:50.259906+00:00 [running]&gt; on host 845928f08686
Started process 152 to run task
Executing &lt;Task(_PythonDecoratedOperator): extract&gt; on 2020-12-02T18:04:50.259906+00:00

--------------------------------------------------------------------------------
Starting attempt 1 of 1

--------------------------------------------------------------------------------
Dependencies all met for &lt;TaskInstance: tutorial_taskflow_api_etl_dag.extract 2020-12-02T18:04:50.259906+00:00 [queued]&gt;
Dependencies all met for &lt;TaskInstance: tutorial_taskflow_api_etl_dag.extract 2020-12-02T18:04:50.259906+00:00 [queued]&gt;

</code></pre></div>
<p dir="auto">The logging configuration is turned on for the Scheduler, Webserver, and Workers. <strong>Log groups and log streams are being created as expected, but log events are not</strong>. There are no errors in the workers, and in AWS the IAM policy permissions are all-inclusive (they also definitely work with SequentialExecutor)</p>
<p dir="auto"><strong>What you expected to happen</strong>:<br>
I expected logs of tasks ran by the celery workers to display for the Webserver when ran with Cloudwatch Remote logging.</p>
<p dir="auto"><strong>How to reproduce it</strong>:<br>
Run Airflow 2.0.0b3 with Webserver in CeleryExecutor mode, two workers, 1 scheduler</p>
<h3 dir="auto">Apache Airflow Provider(s)</h3>
<p dir="auto">datadog</p>
<h3 dir="auto">Versions of Apache Airflow Providers</h3>
<p dir="auto">apache-airflow-providers-datadog==3.0.0</p>
<h3 dir="auto">Apache Airflow version</h3>
<p dir="auto">2.2.2</p>
<h3 dir="auto">Operating System</h3>
<p dir="auto">Mac OS</p>
<h3 dir="auto">Deployment</h3>
<p dir="auto">Amazon (AWS) MWAA</p>
<h3 dir="auto">Deployment details</h3>
<p dir="auto"><em>No response</em></p>
<h3 dir="auto">What happened</h3>
<p dir="auto">I installed the provider package for DataDog. After installation I'm not getting any import errors when using the hook/operator in a DAG file, but I'm unable to create a DataDog connection through the Airflow UI.</p>
<p dir="auto">I noticed in this file where other providers have a Connections section, Datadog does not.<br>
<a href="https://github.com/apache/airflow/blob/main/airflow/providers/datadog/provider.yaml">https://github.com/apache/airflow/blob/main/airflow/providers/datadog/provider.yaml</a></p>
<h3 dir="auto">What you think should happen instead</h3>
<p dir="auto">See above -- I believe some code is missing to actually allow the creation of a DataDog connection.</p>
<h3 dir="auto">How to reproduce</h3>
<p dir="auto">Install the noted version of the Datadog provider package, through the airflow UI attempt to create a DataDog connection.</p>
<h3 dir="auto">Anything else</h3>
<p dir="auto"><em>No response</em></p>
<h3 dir="auto">Are you willing to submit PR?</h3>
<ul class="contains-task-list">
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox" checked=""> Yes I am willing to submit a PR!</li>
</ul>
<h3 dir="auto">Code of Conduct</h3>
<ul class="contains-task-list">
<li class="task-list-item"><input type="checkbox" id="" disabled="" class="task-list-item-checkbox" checked=""> I agree to follow this project's <a href="https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md">Code of Conduct</a></li>
</ul>