diff --git a/airflow/migrations/versions/0057_3_0_0_add_new_task_instance_field_scheduled_.py b/airflow/migrations/versions/0057_3_0_0_add_new_task_instance_field_scheduled_.py index 3f464e45d7c60..ca071a18d0dea 100644 --- a/airflow/migrations/versions/0057_3_0_0_add_new_task_instance_field_scheduled_.py +++ b/airflow/migrations/versions/0057_3_0_0_add_new_task_instance_field_scheduled_.py @@ -42,23 +42,17 @@ def upgrade(): """Apply add new task_instance field scheduled_dttm.""" - # ### commands auto generated by Alembic - please adjust! ### with op.batch_alter_table("task_instance", schema=None) as batch_op: batch_op.add_column(sa.Column("scheduled_dttm", UtcDateTime(timezone=True), nullable=True)) with op.batch_alter_table("task_instance_history", schema=None) as batch_op: batch_op.add_column(sa.Column("scheduled_dttm", UtcDateTime(timezone=True), nullable=True)) - # ### end Alembic commands ### - def downgrade(): """Unapply add new task_instance field scheduled_dttm.""" - # ### commands auto generated by Alembic - please adjust! ### with op.batch_alter_table("task_instance_history", schema=None) as batch_op: batch_op.drop_column("scheduled_dttm") with op.batch_alter_table("task_instance", schema=None) as batch_op: batch_op.drop_column("scheduled_dttm") - - # ### end Alembic commands ### diff --git a/docs/apache-airflow/img/airflow_erd.sha256 b/docs/apache-airflow/img/airflow_erd.sha256 index e3f420e62c1d6..f2bf38552164b 100644 --- a/docs/apache-airflow/img/airflow_erd.sha256 +++ b/docs/apache-airflow/img/airflow_erd.sha256 @@ -1 +1 @@ -829be35e333798f7c33c5fe0130ed12fad481c92145abc398ae23b815dd7b6ed \ No newline at end of file +0f041321ecbb5d059f7a9c85fd5cfba745732eea205dc2e4f5e3b6dd76a9468d \ No newline at end of file