o jEi@sJddlZddlZddlZddlmZeeZdZ ej ddddZ dS)N) celery_appzdiag_output.logz/keepa_deals.env_diag.run_environment_diagnostic)namec Cstdg}|dzddlm}|d|WnY|dt|dtzddl m }|d t |}||td Wn(t y}}zd |}|d ||tj|d dWYd}~nd}~wwz3tjtjtdt}t|d}|d|Wdn1swYtd|Wnt y}ztjd|d dWYd}~nd}~wwtddtS)z Inspects the running Celery worker's environment and records its findings. This acts as a "black box recorder" to see what code the worker has loaded. z,--- Starting Environment Diagnostic Task ---z%--- Environment Diagnostic Report ---r)datetimezTimestamp (UTC): zCurrent Working Directory: zPID: ) backfillerz< --- SOURCE CODE OF LOADED keepa_deals.backfiller MODULE ---zCSuccessfully retrieved source code of the loaded backfiller module.z%Failed to inspect backfiller module: z --- ERROR ---T)exc_infoNz..w z(Successfully wrote diagnostic report to z#Failed to write diagnostic report: z,--- Environment Diagnostic Task Finished ---zDiagnostic report written to )loggerinfoappendrutcnow isoformatosgetcwdgetpid keepa_dealsrinspect getsource Exceptionerrorpathjoindirname__file__DIAG_OUTPUT_FILEopenwrite)output_contentrr source_codee error_message report_pathfr#//var/www/agentarbitrage/keepa_deals/env_diag.pyrun_environment_diagnostic sF              r%) loggingrrworkerrcelery getLogger__name__r rtaskr%r#r#r#r$s