diff --git a/lib/ash/type/type.ex b/lib/ash/type/type.ex
index 159419d6..0017bdfe 100644
--- a/lib/ash/type/type.ex
+++ b/lib/ash/type/type.ex
@@ -328,7 +328,11 @@ defmodule Ash.Type do
   end
 
   def ecto_type(type) do
-    type.ecto_type()
+    if Ash.Resource.Info.resource?(type) do
+      Module.concat(type, EctoType)
+    else
+      type.ecto_type()
+    end
   end
 
   def ash_type_option(type) do