Fix for Windows

airflow/jobs/local_task_job.py

@@ -263,7 +263,10 @@ def heartbeat_callback(self, session=None):
                 recorded_pid = psutil.Process(ti.pid).ppid()
                 same_process = recorded_pid == current_pid
 
-            if recorded_pid is not None and not same_process:
+            if not IS_WINDOWS and recorded_pid is not None and not same_process:
+                # On Windows this sometimes does not work properly as the system seems to change
+                # PIDs in some situations. Since this prohibits using Windows systems for task
+                # execution, this check is skipped until the cause for this can be determined.
                 self.log.warning(
                     "Recorded pid %s does not match the current pid %s", recorded_pid, current_pid
                 )

airflow/utils/process_utils.py

@@ -80,6 +80,8 @@ def on_terminate(p):
         returncodes[p.pid] = p.returncode
 
     def signal_procs(sig):
+        if IS_WINDOWS:
+            return
         try:
             logger.info("Sending the signal %s to group %s", sig, process_group_id)
             os.killpg(process_group_id, sig)
@@ -108,7 +110,7 @@ def signal_procs(sig):
             else:
                 raise
 
-    if process_group_id == os.getpgid(0):
+    if not IS_WINDOWS and process_group_id == os.getpgid(0):
         raise RuntimeError("I refuse to kill myself")
 
     try: