Deprecate BatchSensorAsync

[Lee-W]

What's changed

Deprecate BatchSensorAsync and fallback to BatchSensor with deferrable=True

Why this change

The logic of BatchSensorAsync bas been contributed back to OSS airflow as part of BatchSensor

BatchSensorAsync

astronomer-providers/astronomer/providers/amazon/aws/sensors/batch.py

Lines 46 to 68 in b5a9417

	def execute(self, context: Context) -> None:
	"""Defers trigger class to poll for state of the job run until it reaches a failure or a success state"""
	if not poke(self, context):
	self.defer(
	timeout=timedelta(seconds=self.timeout),
	trigger=BatchSensorTrigger(
	job_id=self.job_id,
	aws_conn_id=self.aws_conn_id,
	region_name=self.region_name,
	poke_interval=self.poke_interval,
	),
	method_name="execute_complete",
	)
	def execute_complete(self, context: Context, event: Dict[str, Any]) -> None:
	"""
	Callback for when the trigger fires - returns immediately.
	Relies on trigger to throw an exception, otherwise it assumes execution was
	successful.
	"""
	if "status" in event and event["status"] == "error":
	raise_error_or_skip_exception(self.soft_fail, event["message"])
	self.log.info(event["message"])

BatchSensor

https://github.com/apache/airflow/blob/999b70178a1f5d891fd2c88af4831a4ba4c2cbc9/airflow/providers/amazon/aws/sensors/batch.py#L98-L133

[codecov]

Codecov Report

All modified and coverable lines are covered by tests ✅

Comparison is base (6781996) 98.57% compared to head (bdc99ef) 98.56%.

Additional details and impacted files

@@            Coverage Diff             @@
##             main    #1391      +/-   ##
==========================================
- Coverage   98.57%   98.56%   -0.02%     
==========================================
  Files          91       91              
  Lines        5460     5421      -39     
==========================================
- Hits         5382     5343      -39     
  Misses         78       78              

☔ View full report in Codecov by Sentry.
📢 Have feedback on the report? Share it here.

[phanikumv]

what about the integration DAGs that might be using this class, are we planning to remove them at a later point of time?

[phanikumv]

Please add description about why you are doing this change

[Lee-W]

what about the integration DAGs that might be using this class, are we planning to remove them at a later point of time?

Yes, I think we should keep it for a while and remove it after we deprecate the whole repo.

Please add description about why you are doing this change

Sure. let me reformat and reword it to make it easier to read.