pass through retry_policy in dbt_asset

python_modules/libraries/dagster-dbt/dagster_dbt/asset_decorator.py

@@ -23,6 +23,7 @@
     DagsterInvalidDefinitionError,
     Nothing,
     PartitionsDefinition,
+    RetryPolicy,
     TimeWindowPartitionsDefinition,
     multi_asset,
 )
@@ -78,6 +79,7 @@ def dbt_assets(
     op_tags: Optional[Mapping[str, Any]] = None,
     required_resource_keys: Optional[Set[str]] = None,
     project: Optional[DbtProject] = None,
+    retry_policy: Optional[RetryPolicy] = None,
 ) -> Callable[[Callable[..., Any]], AssetsDefinition]:
     """Create a definition for how to compute a set of dbt resources, described by a manifest.json.
     When invoking dbt commands using :py:class:`~dagster_dbt.DbtCliResource`'s
@@ -403,6 +405,7 @@ def partitionshop_dbt_assets(context: AssetExecutionContext, dbt: DbtCliResource
         op_tags=resolved_op_tags,
         check_specs=check_specs,
         backfill_policy=backfill_policy,
+        retry_policy=retry_policy,
     )