import hou
import pdg

topnode_path = '/tasks/topnet1/genericgenerator1'
top_node = hou.node(topnode_path)

# 大元のPDGグラフにアクセスできるようにするために、必ずTOPグラフをクックします。
top_node.cookWorkItems(tops_only=True)

pdg_node = top_node.getPDGNode()
pdg_context = top_node.getPDGGraphContext()

# ワークアイテムイベントを制御する関数を定義します。
def print_add(event):
    work_item = pdg_context.graph.workItemById(event.workItemId)
    print ("Work item '{}' was added to node {}".format(work_item.name, event.node.name))
    # ステートの変更を受信するためのリスナーをこの新しいワークアイテム上に追加します。

    def print_workitem_change(event):
        work_item = pdg_context.graph.workItemById(event.workItemId)
        print ('State Change for {}: {} -> {}'.format(work_item.name, event.lastState, event.currentState))
    work_item.addEventHandler(print_workitem_change, pdg.EventType.WorkItemStateChange)

# グラフレベルのイベントを制御する関数を定義します。
def print_done(event):
    print ("Graph cook complete!")

# ハンドラーを登録します。
node_handler = pdg_node.addEventHandler(print_add, pdg.EventType.WorkItemAdd)
context_handler = pdg_context.addEventHandler(print_done, pdg.EventType.CookComplete)

pdg_node.removeEventHandler(node_handler)

def print_done_and_remove(handler, event):
    print ("Graph cook complete!")

    # リッスンしているすべてのイベントからハンドラーの登録を解除します。
    handler.removeFromAllEmitters()

pdg_context.addEventHandler(print_done_and_remove, pdg.EventType.CookComplete, True)

import hdefereval

# メッセージを表示するための関数を定義します。
def display_message(message):
    import hou
    hou.ui.displayMessage(message, title="Example Message from PDG")

# イベントハンドラーを定義します。
def display_event(event):
    hdefereval.executeDeferred(display_message, "An example message created in"
        " a PDG Event but displayed from the main thread!")

pdg_context.addEventHandler(display_event, pdg.EventType.CookComplete)