def on_created()

in src/smspark/spark_executor_logs_watcher.py [0:0]

• 8 lines of code
• 3 McCabe index (conditional complexity)

    def on_created(event: FileSystemEvent) -> None:
        """Tail executor logs upon filesystem create event."""
        if event.is_directory:
            return None

        print(f"Handling create event for file: {event.src_path}")
        p1 = Popen(["tail", "-f", event.src_path], stdout=PIPE)
        Popen(["sed", f"s~^~[{event.src_path}] ~"], stdin=p1.stdout)
        if p1.stdout is not None:
            p1.stdout.close()