test_sensor.py

from dagster import job, op, Failure, sensor, RunRequest
from test_job import test_job
from dagster_celery import celery_executor
from dagster.core.storage.pipeline_run import (
    RunsFilter,
    PipelineRunStatus,
)


@op
def run_test_job(context):
    context.log.info(f'Hello!')
                  

@job(executor_def=celery_executor)
def run_job():   
    run_test_job()
  

if __name__ == "__main__":
    result = run_job.execute_in_process()

dagster.core.errors.DagsterImportError: Encountered ImportError: No module named 'test_job' while importing module repo from file /opt/dagster/app/repo.py. Local modules were resolved using the working directory /opt/dagster/app. If another working directory should be used, please explicitly specify the appropriate path using the -d or --working-directory for CLI based targets or the working_directory configuration option for python_file-based workspace targets.