dag_id = "test-dag"
    ti = create_task_instance(dag_id=dag_id, session=session)
    ltj = Job(dag_id=ti.dag_id)
    LocalTaskJobRunner(job=ltj, task_instance=ti)
    ltj.state = State.RUNNING
    session.commit()
    pydantic_job = JobPydantic.model_validate(ltj)
    json_string = pydantic_job.model_dump_json()
    print(json_string)
    deserialized_model = JobPydantic.model_validate_json(json_string)
    assert deserialized_model.dag_id == dag_id
    assert deserialized_model.job_type == "LocalTaskJob"
    assert deserialized_model.state == State.RUNNING
@pytest.mark.skipif(not _ENABLE_AIP_44, reason="AIP-44 is disabled")
def test_serializing_pydantic_dataset_event(session, create_task_instance, create_dummy_dag):