scheduler

Body

days_ago is deprecated apache/airflow#21653

We have several references to the function in test suite / example dags.

Task:
there should be no imports of airflow.utils.dates import days_ago in the code.
In most cases we can simple replace with datetime(2022, 1, 1)

Committer

• I acknowledge that I am a maintainer/committer of the Apache Airfl

Right now, we've got this chunk of code:

def _columns_to_markdown(columns: Mapping[str, Any]) -> str:
    return (
        textwrap.dedent(
            """
        | Name | Description |
        | - | - |
    """
        )
        + "\n".join([f"| {name} | {metadata['description']}" for name, metadata in columns.items()])
    )

Instead of representing them with markdown, we

Is there a way to make a job re-occur N milliseconds after it finished previous time?

The tests fail sometimes due to millisecond based timing on some of the tests. I over optimized for local testing and it's causing tests to fail in CI occasionally. The CI pipeline is running in docker with limited resources, so not able to handle quite as precise time as my local machine.