Show partial backfill details in drawer

assets/svelte/consumers/ShowBackfills.svelte

@@ -328,6 +328,29 @@
               >{selectedBackfill.table_name}</span
             >
           </div>
+          {#if selectedBackfill.sort_column_name}
+            <div class="flex justify-between items-center">
+              <span class="text-sm font-medium text-gray-500">Type:</span>
+              <span class="text-sm text-gray-900">Partial</span>
+            </div>
+            <div class="flex justify-between items-center">
+              <span class="text-sm font-medium text-gray-500">Sort Column:</span
+              >
+              <span class="text-sm text-gray-900"
+                >{selectedBackfill.sort_column_name}</span
+              >
+            </div>
+            {#if selectedBackfill.start_value != null}
+              <div class="flex justify-between items-center">
+                <span class="text-sm font-medium text-gray-500"
+                  >Start Value:</span
+                >
+                <span class="text-sm text-gray-900"
+                  >{selectedBackfill.start_value}</span
+                >
+              </div>
+            {/if}
+          {/if}
           {#if selectedBackfill.rows_initial_count !== null}
             <div class="flex justify-between items-center">
               <span class="text-sm font-medium text-gray-500">Total Rows:</span>

lib/sequin/transforms/transforms.ex

@@ -1619,6 +1619,7 @@ defmodule Sequin.Transforms do
   end
 
   # Helper to parse auth_type
+  defp parse_auth_type("none"), do: :none
   defp parse_auth_type("api_key"), do: :api_key
   defp parse_auth_type("basic"), do: :basic
   defp parse_auth_type("bearer"), do: :bearer

lib/sequin_web/live/sink_consumers/show.ex

@@ -1676,6 +1676,17 @@ defmodule SequinWeb.SinkConsumersLive.Show do
 
     table_name = if table, do: "#{table.schema}.#{table.name}", else: "Unknown table"
 
+    sort_column_name =
+      if table && backfill.sort_column_attnum do
+        column = Enum.find(table.columns, &(&1.attnum == backfill.sort_column_attnum))
+        if column, do: column.name
+      end
+
+    start_value =
+      if sort_column_name && backfill.initial_min_cursor do
+        Map.get(backfill.initial_min_cursor, backfill.sort_column_attnum)
+      end
+
     %{
       id: backfill.id,
       state: backfill.state,
@@ -1689,7 +1700,9 @@ defmodule SequinWeb.SinkConsumersLive.Show do
       failed_at: backfill.failed_at,
       updated_at: backfill.updated_at,
       progress: calculate_backfill_progress(backfill),
-      error: if(backfill.error, do: Exception.message(backfill.error))
+      error: if(backfill.error, do: Exception.message(backfill.error)),
+      sort_column_name: sort_column_name,
+      start_value: start_value
     }
   end
 

test/sequin/yaml_loader_test.exs

@@ -1493,6 +1493,36 @@ defmodule Sequin.YamlLoaderTest do
              } = consumer.sink
     end
 
+    test "creates elasticsearch sink consumer with auth_type none" do
+      assert :ok =
+               YamlLoader.apply_from_yml!("""
+               #{account_and_db_yml()}
+
+               sinks:
+                 - name: "elasticsearch-no-auth"
+                   database: "test-db"
+                   destination:
+                     type: "elasticsearch"
+                     endpoint_url: "https://elasticsearch.example.com"
+                     index_name: "test-index"
+                     auth_type: "none"
+                     batch_size: 100
+               """)
+
+      assert [consumer] = Repo.all(SinkConsumer)
+
+      assert consumer.name == "elasticsearch-no-auth"
+
+      assert %ElasticsearchSink{
+               type: :elasticsearch,
+               endpoint_url: "https://elasticsearch.example.com",
+               index_name: "test-index",
+               auth_type: :none,
+               auth_value: nil,
+               batch_size: 100
+             } = consumer.sink
+    end
+
     test "creates redis string sink consumer" do
       assert :ok =
                YamlLoader.apply_from_yml!("""