diff --git a/.github/workflows/pull-request-checks.yaml b/.github/workflows/pull-request-checks.yaml
index 800368824be90..0ad9ec1a294b6 100644
--- a/.github/workflows/pull-request-checks.yaml
+++ b/.github/workflows/pull-request-checks.yaml
@@ -21,6 +21,7 @@ jobs:
     - uses: jitterbit/get-changed-files@v1
       id: changed_files
       name: Get changed files
+      continue-on-error: true
     - id: md_changed_files
       name: Spellcheck Markdown files
       run: |-
@@ -93,6 +94,7 @@ jobs:
         uses: jitterbit/get-changed-files@v1
         with:
           format: 'space-delimited'
+        continue-on-error: true
       - name: Lint changed files
         run: npx eslint --quiet ${{ steps.changed_files_space.outputs.added_modified }} ${{ steps.changed_files_space.outputs.renamed }}
       - name: Get Changed Files (comma-separated)
@@ -100,6 +102,7 @@ jobs:
         uses: jitterbit/get-changed-files@v1
         with:
           format: 'csv'
+        continue-on-error: true
       # NOTE: These steps are kept in this workflow to avoid re-rerunning the rest of the lint job
       # in the Components Checks workflow 
       - name: Check component keys
diff --git a/types/src/index.ts b/types/src/index.ts
index 80a5d8183339d..01846d400223c 100644
--- a/types/src/index.ts
+++ b/types/src/index.ts
@@ -310,15 +310,25 @@ export interface EmitMetadata {
   ts?: number;
 }
 
+export interface IdEmitMetadata extends EmitMetadata {
+  id: string | number;
+}
+
 type EmitFunction = {
   $emit: (event: JSONValue, metadata?: EmitMetadata) => Promise<void>;
 };
 
+type IdEmitFunction = {
+  $emit: (event: JSONValue, metadata: IdEmitMetadata) => Promise<void>;
+};
+
 type PropThis<Props> = {
   [Prop in keyof Props]: Props[Prop] extends App<Methods, AppPropDefinitions> ? any : any
 };
 
-export interface Source<
+type Modify<T, R> = Omit<T, keyof R> & R;
+
+interface BaseSource<
   Methods,
   SourcePropDefinitions
 > {
@@ -337,6 +347,38 @@ export interface Source<
   run: (this: PropThis<SourcePropDefinitions> & Methods & EmitFunction, options?: SourceRunOptions) => void | Promise<void>;
 }
 
+export interface LastSource<
+  Methods,
+  SourcePropDefinitions
+> extends BaseSource<
+  Methods,
+  SourcePropDefinitions
+> {
+  dedupe?: "last";
+}
+
+export type DedupedSource<
+  Methods,
+  SourcePropDefinitions
+> = Modify<BaseSource<
+  Methods,
+  SourcePropDefinitions
+>, {
+  dedupe: "greatest" | "unique";
+  run: (this: PropThis<SourcePropDefinitions> & Methods & IdEmitFunction, options?: SourceRunOptions) => void | Promise<void>;
+}>;
+
+export type Source<
+  Methods,
+  SourcePropDefinitions
+> = LastSource<
+  Methods,
+  SourcePropDefinitions
+> | DedupedSource<
+  Methods,
+  SourcePropDefinitions
+>;
+
 export function defineSource<
   Methods,
   SourcePropDefinitions,
diff --git a/types/src/types.test.ts b/types/src/types.test.ts
index 7178af09fd261..5812ed35d3d7f 100644
--- a/types/src/types.test.ts
+++ b/types/src/types.test.ts
@@ -352,3 +352,17 @@ const actionWrongType: Pipedream.Action<Pipedream.Methods, Pipedream.ActionPropD
   type: "source",
   run() { console.log("foo"); },
 };
+
+Pipedream.defineSource({
+  key: "source",
+  version: "0.0.1",
+  type: "source",
+  dedupe: "unique",
+  run() {
+    this.$emit(
+      {},
+      // @ts-expect-error $ExpectError - Missing id property in metadata object
+      {},
+    );
+  },
+});