fix: Breaking changes in new dulwich version

airflow_dbt_python/hooks/fs/git.py

@@ -93,10 +93,10 @@ def _upload(
             if self.upload_filter(f) is False:
                 continue
 
-            repo.stage(str(f.relative_to(source)))
+            repo.get_worktree().stage([str(f.relative_to(source))])
 
         ts = dt.datetime.now(dt.timezone.utc)
-        repo.do_commit(
+        repo.get_worktree().commit(
             self.commit_msg.format(ts=ts).encode(), self.commit_author.encode()
         )
 

pyproject.toml

@@ -51,7 +51,7 @@ gcs = [
 ]
 git = [
     "apache-airflow-providers-ssh>=3.0.0",
-    "dulwich>=0.24.3",
+    "dulwich>=1.0.0",
 ]
 postgres = [
     "dbt-postgres>=1.8.0,<2.0.0",

tests/hooks/test_git_hook.py

@@ -317,20 +317,23 @@ def repo_dir(tmp_path):
 def repo(repo_dir, dbt_project_file, test_files, profiles_file, repo_branch):
     """Initialize a git repo with some dbt test files."""
     repo = Repo.init(repo_dir, default_branch=repo_branch)
+
     shutil.copyfile(dbt_project_file, repo_dir / "dbt_project.yml")
-    repo.stage("dbt_project.yml")
+    repo.get_worktree().stage("dbt_project.yml")
 
     shutil.copyfile(profiles_file, repo_dir / "profiles.yml")
-    repo.stage("profiles.yml")
+    repo.get_worktree().stage("profiles.yml")
 
     for test_file in test_files:
         remote_subdir = repo_dir / test_file.parent.name
         remote_subdir.mkdir(exist_ok=True)
         shutil.copyfile(test_file, remote_subdir / test_file.name)
 
-        repo.stage(f"{test_file.parent.name}/{test_file.name}")
+        repo.get_worktree().stage(f"{test_file.parent.name}/{test_file.name}")
 
-    repo.do_commit(b"Test first commit", committer=b"Test user <test@user.com>")
+    repo.get_worktree().commit(
+        b"Test first commit", committer=b"Test user <test@user.com>"
+    )
 
     yield repo
 
@@ -341,7 +344,7 @@ def repo(repo_dir, dbt_project_file, test_files, profiles_file, repo_branch):
 def git_server(repo, repo_name):
     """A testing local TCP git server."""
     backend = DictBackend({repo_name.encode(): repo})
-    dul_server = TCPGitServer(backend, b"localhost", 0)
+    dul_server = TCPGitServer(backend, "localhost", 0)
 
     server_thread = threading.Thread(target=dul_server.serve)
     server_thread.start()
@@ -351,6 +354,8 @@ def git_server(repo, repo_name):
     yield server_address, server_port
 
     dul_server.shutdown()
+    dul_server.server_close()
+
     server_thread.join()