The GitHub Actions job "Tests (AMD)" on airflow.git/deferrable-dynamodb-value-sensor has failed. Run started by GitHub user harshhh817 (triggered by potiuk).
Head commit for run: 1156b3da57b740a0d047810941710b72efc20e82 / Harsh Gupta <[email protected]> Add deferrable mode to DynamoDBValueSensor DynamoDBValueSensor previously only supported poke/reschedule modes, occupying a worker slot while waiting for a DynamoDB attribute value. This adds the standard deferrable path used across the Amazon provider: - deferrable param (defaulting to the operators.default_deferrable config) on DynamoDBValueSensor; when set, execute() defers to a new DynamoDBValueSensorTrigger and execute_complete() validates the event. - DynamoDBValueSensorTrigger polls the item asynchronously. Since aiobotocore only exposes clients (DynamoDBHook is resource-based), the trigger uses a client-type AwsBaseHook and deserializes the typed attribute with boto3's TypeDeserializer before comparing, keeping poke semantics identical to the sync path (ClientError tolerated, string or iterable of strings matched). - Registered the trigger module in provider.yaml/get_provider_info, plus unit tests for the sensor deferral and the trigger. The issue title suggests DynamoDB Streams + SQS, but async polling is the established pattern for amazon provider deferrable sensors (SQS, EC2, ...), so this follows that convention. closes: #69051 Signed-off-by: Harsh Gupta <[email protected]> Report URL: https://github.com/apache/airflow/actions/runs/29226432696 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
